try_parse_json

Analizza una colonna contenente una stringa JSON in un oggetto VariantType. Restituisce Nessuno se una stringa contiene un valore JSON non valido.

Sintassi

from pyspark.sql import functions as sf

sf.try_parse_json(col)

Parametri

Parametro	TIPO	Description
col	pyspark.sql.Column o str	Stringhe in formato JSON con nome di colonna o colonna.

Restituzioni

pyspark.sql.Column: nuova colonna di VariantType.

Esempi

from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }'''}, {'json': '''{a : 1}'''} ])
df.select(sf.to_json(sf.try_parse_json(df.json))).collect()

[Row(to_json(try_parse_json(json))='{"a":1}'), Row(to_json(try_parse_json(json))=None)]