Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

OpenX JSON SerDe

Comme le Hive JSON SerDe, vous pouvez utiliser JSON OpenX pour JSON traiter les données. Les données sont également représentées sous forme de chaînes de texte JSON codé d'une seule ligne séparées par une nouvelle ligne. Comme le Hive JSON SerDe, JSON SerDe OpenX n'autorise pas la duplication de clés struct ou de noms map de clés.

Considérations et restrictions

Propriétés facultatives

Contrairement au Hive JSON SerDe, l'JSON SerDe OpenX possède également les propriétés SerDe facultatives suivantes qui peuvent être utiles pour corriger les incohérences dans les données.

Exemple : données publicitaires

L'exemple d'DDLinstruction suivant utilise OpenX JSON SerDe pour créer un tableau basé sur les mêmes exemples de données publicitaires en ligne que ceux utilisés dans l'exemple de The Hive. JSON SerDe Dans la LOCATION clause, remplacez myregion avec l'identifiant de la région dans laquelle vous exécutez Athena.

CREATE EXTERNAL TABLE impressions (
    requestbegintime string,
    adid string,
    impressionId string,
    referrer string,
    useragent string,
    usercookie string,
    ip string,
    number string,
    processid string,
    browsercokie string,
    requestendtime string,
    timers struct<
       modellookup:string, 
       requesttime:string>,
    threadid string, 
    hostname string,
    sessionid string
)   PARTITIONED BY (dt string)
ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe'
LOCATION 's3://amzn-s3-demo-bucket.elasticmapreduce/samples/hive-ads/tables/impressions';

Exemple : désérialisation d'imbriqué JSON

Vous pouvez utiliser le JSON SerDes pour analyser des données JSON codées plus complexes. Cela implique l'utilisation d'instructions CREATE TABLE utilisant des éléments struct et array pour représenter des structures imbriquées.

L'exemple suivant crée une table Athena à partir de JSON données comportant des structures imbriquées. L'exemple présente la structure suivante :

{
"DocId": "AWS",
"User": {
        "Id": 1234,
        "Username": "carlos_salazar", 
        "Name": "Carlos",
"ShippingAddress": {
"Address1": "123 Main St.",
"Address2": null,
"City": "Anytown",
"State": "CA"
   },
"Orders": [
   {
     "ItemId": 6789,
     "OrderDate": "11/11/2022" 
   },
   {
     "ItemId": 4352,
     "OrderDate": "12/12/2022"
   }
  ]
 }
}

N'oubliez pas que l'OpenX SerDe s'attend à ce que chaque JSON enregistrement se trouve sur une seule ligne de texte. Lorsqu'elles sont stockées dans Amazon S3, toutes les données de l'exemple précédent doivent se trouver sur une seule ligne, comme ceci :

{"DocId":"AWS","User":{"Id":1234,"Username":"carlos_salazar","Name":"Carlos","ShippingAddress" ...

L'CREATE TABLEinstruction suivante utilise le Openx- JsonSerDe avec les types de données de array collecte struct et pour établir des groupes d'objets pour les données d'exemple.

CREATE external TABLE complex_json (
   docid string,
   `user` struct<
               id:INT,
               username:string,
               name:string,
               shippingaddress:struct<
                                      address1:string,
                                      address2:string,
                                      city:string,
                                      state:string
                                      >,
               orders:array<
                            struct<
                                 itemid:INT,
                                  orderdate:string
                                  >
                              >
               >
   )
ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe'
LOCATION 's3://amzn-s3-demo-bucket/myjsondata/';

Pour interroger la table, utilisez une SELECT instruction comme celle-ci.

SELECT 
 user.name as Name, 
 user.shippingaddress.address1 as Address, 
 user.shippingaddress.city as City, 
 o.itemid as Item_ID, o.orderdate as Order_date
FROM complex_json, UNNEST(user.orders) as temp_table (o)

Pour accéder aux champs de données à l'intérieur des structures, l'exemple de requête utilise la notation par points (par exemple,user.name). Pour accéder aux données d'un tableau de structures (comme pour le orders champ), vous pouvez utiliser la UNNEST fonction. La UNNEST fonction aplatit le tableau pour en faire une table temporaire (appelée o dans ce cas). Cela vous permet d'utiliser la notation par points comme vous le feriez avec les structures pour accéder aux éléments de tableau non imbriqués (par exemple,). o.itemid Le nomtemp_table, utilisé dans l'exemple à des fins d'illustration, est souvent abrégé en. t

Le tableau suivant présente les résultats de la requête.