try_parse_json

Analisa uma coluna que contém uma cadeia de caracteres JSON em um VariantType. Retorna Nenhum se uma cadeia de caracteres contiver um valor JSON inválido.

Sintaxe

from pyspark.sql import functions as sf

sf.try_parse_json(col)

Parâmetros

Parâmetro	Tipo	Description
col	pyspark.sql.Column ou str	Uma coluna ou coluna nome cadeias de caracteres formatadas JSON.

Devoluções

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

Exemplos

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