Data Hub Writer

Le node Data Hub Writer insère, met à jour, fusionne ou supprime des lignes dans les tables du Data Hub de votre organisation, sans intégration à configurer.

À quoi sert le node Data Hub Writer ?#

Le node Data Hub Writer exécute une requête INSERT, UPDATE, MERGE ou DELETE sur les tables du Data Hub de votre organisation. Il fonctionne comme le Google BigQuery Writer, avec le même éditeur SQL, la même gestion des tableaux et la même sortie, mais sans intégration BigQuery : la requête s’exécute avec l’identité Data Hub de votre organisation, qui ne peut écrire que dans les datasets de votre organisation.

Cas d’usage courants :

• Enregistrer le contenu généré par produit (titres, descriptions) dans une table du Data Hub
• Stocker des classifications ou des scores calculés par un workflow lancé depuis un pipeline Data Hub
• Mettre à jour ou fusionner des lignes d’une table du Data Hub depuis un workflow

Configuration rapide#

Paramètres de configuration#

Champs obligatoires#

INSERT INTO dng_org_123456789_eu.product_content (sku_id, new_title, updated_at)
VALUES ('{{sku_id}}', r"""{{new_title}}""", CURRENT_TIMESTAMP())

Que produit le node en sortie ?#

{
  "success": true,
  "query_type": "insert",
  "job_id": "job_abc123",
  "job_ids": ["job_abc123"],
  "num_dml_affected_rows": 1,
  "total_bytes_processed": 0,
  "chunks": 1
}

Exemples d’utilisation#

Exemple 1 : enregistrer un titre généré par produit#

Lancez le workflow depuis une étape batch d’un pipeline Data Hub (une exécution par produit), générez le titre avec un LLM, puis :

• Query Type : insert
• SQL Query :

  INSERT INTO dng_org_123456789_eu.product_content (sku_id, new_title, updated_at)
  VALUES ('{{sku_id}}', r"""{{new_title}}""", CURRENT_TIMESTAMP())

Exemple 2 : fusionner une liste de résultats#

Un Code Block renvoie les résultats sous forme de tableau JSON dans items :

• Query Type : merge
• SQL Query :

  MERGE dng_org_123456789_eu.gpc_results T
  USING (
    SELECT JSON_VALUE(item, '$.sku_id') AS sku_id,
           JSON_VALUE(item, '$.gpc_path') AS gpc_path
    FROM UNNEST(JSON_QUERY_ARRAY(r'''{{items}}''')) AS item
  ) S
  ON T.sku_id = S.sku_id
  WHEN MATCHED THEN UPDATE SET gpc_path = S.gpc_path
  WHEN NOT MATCHED THEN INSERT (sku_id, gpc_path) VALUES (S.sku_id, S.gpc_path)

Problèmes courants#

Bonnes pratiques#

Nodes associés#