tente_analisar_json

Analisa uma coluna contendo strings JSON em um VariantType. Retorna None se a string contiver um valor JSON inválido.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.try_parse_json(col)

Parâmetros

Parâmetro	Tipo	Descrição
col	pyspark.sql.Column ou str	Uma coluna ou nome de strings em formato JSON .

Devoluções

pyspark.sql.Column: uma nova coluna de VariantType.

Exemplos

Python

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()

Output

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