unix_timestamp

Konvertera en tidssträng med det angivna mönstret ('åååå-MM-dd HH:mm:ss', som standard) till en Unix-tidsstämpel (i sekunder) med standardtidszon och standardlocale. Returnerar null om det misslyckas. Om timestamp är Ingen returnerar den aktuell tidsstämpel.

För motsvarande Databricks SQL-funktion, se unix_timestamp funktion.

Syntax

import pyspark.sql.functions as sf

# Returns current timestamp
sf.unix_timestamp()

# With timestamp
sf.unix_timestamp(timestamp=<timestamp>)

# With timestamp and format
sf.unix_timestamp(timestamp=<timestamp>, format=<format>)

Parameterar

Retur

pyspark.sql.Column: unix time as long heltal.

Examples

Exempel 1: Returnerar den aktuella tidsstämpeln i UNIX.

import pyspark.sql.functions as sf
spark.range(1).select(sf.unix_timestamp()).show()

+----------+
| unix_time|
+----------+
|1702018137|
+----------+

Exempel 2: Med standardformatet "åååå-MM-dd HH:mm:ss" parsas tidsstämpelsträngen.

import pyspark.sql.functions as sf
df = spark.createDataFrame([('2015-04-08 12:12:12',)], ['ts'])
df.select('*', sf.unix_timestamp('ts')).show()

+-------------------+---------------------------------------+
|                 ts|unix_timestamp(ts, yyyy-MM-dd HH:mm:ss)|
+-------------------+---------------------------------------+
|2015-04-08 12:12:12|                             1428520332|
+-------------------+---------------------------------------+

Exempel 3: Med det användardefinierade formatet "åååå-MM-dd" parsas tidsstämpelsträngen.

import pyspark.sql.functions as sf
df = spark.createDataFrame([('2015-04-08',)], ['dt'])
df.select('*', sf.unix_timestamp('dt', 'yyyy-MM-dd')).show()

+----------+------------------------------+
|        dt|unix_timestamp(dt, yyyy-MM-dd)|
+----------+------------------------------+
|2015-04-08|                    1428476400|
+----------+------------------------------+