get_json_object

Extrait l’objet json d’une chaîne json basée sur path json spécifié et retourne la chaîne json de l’objet json extrait. Elle retourne null si la chaîne json d’entrée n’est pas valide.

Syntaxe

from pyspark.sql import functions as sf

sf.get_json_object(col, path)

Paramètres

Paramètre	Type	Descriptif
col	pyspark.sql.Column ou str	Colonne de chaîne au format json.
path	str	Chemin d’accès à l’objet json à extraire.

Retours

pyspark.sql.Column: représentation sous forme de chaîne d’une valeur d’objet JSON donnée.

Examples

Exemple 1 : Extraire un objet json à partir d’une chaîne json

from pyspark.sql import functions as sf
data = [("1", '''{"f1": "value1", "f2": "value2"}'''), ("2", '''{"f1": "value12"}''')]
df = spark.createDataFrame(data, ("key", "jstring"))
df.select(df.key,
    sf.get_json_object(df.jstring, '$.f1').alias("c0"),
    sf.get_json_object(df.jstring, '$.f2').alias("c1")
).show()

+---+-------+------+
|key|     c0|    c1|
+---+-------+------+
|  1| value1|value2|
|  2|value12|  NULL|
+---+-------+------+

Exemple 2 : Extraire un objet json à partir d’un tableau json

from pyspark.sql import functions as sf
data = [
("1", '''[{"f1": "value1"},{"f1": "value2"}]'''),
("2", '''[{"f1": "value12"},{"f2": "value13"}]''')
]
df = spark.createDataFrame(data, ("key", "jarray"))
df.select(df.key,
    sf.get_json_object(df.jarray, '$[0].f1').alias("c0"),
    sf.get_json_object(df.jarray, '$[1].f2').alias("c1")
).show()

+---+-------+-------+
|key|     c0|     c1|
+---+-------+-------+
|  1| value1|   NULL|
|  2|value12|value13|
+---+-------+-------+

df.select(df.key,
    sf.get_json_object(df.jarray, '$[*].f1').alias("c0"),
    sf.get_json_object(df.jarray, '$[*].f2').alias("c1")
).show()

+---+-------------------+---------+
|key|                 c0|       c1|
+---+-------------------+---------+
|  1|["value1","value2"]|     NULL|
|  2|          "value12"|"value13"|
+---+-------------------+---------+