Aller au contenu principal
Dernière mise à jour le

Ingérer des données depuis Reddit Ads

info

Bêta

Cette fonctionnalité est en Bêta. Les administrateurs du Workspace peuvent contrôler l'accès à cette fonctionnalité à partir de la page Previews . Consultez Gérer les aperçus Databricks.

Découvrez comment créer un pipeline d'ingestion géré pour ingérer des données de Reddit Ads dans Databricks.

Exigences​

  • Pour créer un pipeline d'ingestion, vous devez remplir les conditions suivantes :

    • Votre workspace doit être activé pour Unity Catalog.

    • Le compute Serverless doit être activé pour votre Workspace. Consultez les exigences du compute Serverless.

    • Pour créer une nouvelle connexion, vous devez disposer des privilèges CREATE CONNECTION sur le métastore. Voir Gérer les privilèges dans Unity Catalog.

      Si le connecteur prend en charge la création de pipelines basée sur l'interface utilisateur, un administrateur peut créer la connexion et le pipeline en même temps en suivant les étapes décrites sur cette page. Cependant, si les utilisateurs qui créent des pipelines utilisent la création de pipelines basée sur l'API ou ne sont pas des utilisateurs administrateurs, un administrateur doit d'abord créer la connexion dans l'Explorateur de catalogues. Voir Connexion aux sources d'ingestion gérées.

    • Pour utiliser une connexion existante, vous devez avoir les privilèges USE CONNECTION ou ALL PRIVILEGES sur l'objet de connexion.

    • Vous devez disposer de privilèges USE CATALOG sur le catalogue cible.

    • Vous devez disposer des privilèges USE SCHEMA et CREATE TABLE sur un schéma existant ou des privilèges CREATE SCHEMA sur le catalogue cible.

  • Pour ingérer des données depuis Reddit Ads, vous devez effectuer les étapes de Créer une connexion Reddit Ads.

Schémas source​

Reddit Ads organise les tables en schémas sources (espaces de noms) :

  • La table d’entités ad_account se trouve dans le schéma spécial default (source_schema: "default"). Il répertorie les comptes publicitaires accessibles à l’utilisateur authentifié.
  • Toutes les tables à l'échelle du compte — campaign, ad_group, ad et toutes les tables de rapport — se trouvent sous un schéma nommé par l'ID du compte publicitaire (source_schema: "<ad_account_id>").

Créez un pipeline d'ingestion​

  1. Dans la barre latérale du workspace Databricks, cliquez sur Ingestion de données .
  2. Sur la page Ajouter des données , sous Connecteurs Databricks , cliquez sur Annonces Reddit .
  3. Sur la page Connexion de l'assistant d'ingestion, sélectionnez la connexion qui stocke vos identifiants d'accès Reddit Ads. Si vous disposez du privilège CREATE CONNECTION sur le metastore, vous pouvez cliquer sur Icône Plus. Créer une connexion pour créer une nouvelle connexion avec les détails d'authentification dans Créer une connexion Reddit Ads.
  4. Cliquez sur Suivant .
  5. Sur la page **Configuration de l'ingestion**, saisissez un nom unique pour le pipeline.
  6. Sélectionnez un catalogue et un schéma pour écrire les Logs d'événements. Si vous disposez des privilèges USE CATALOG et CREATE SCHEMA sur le catalogue, vous pouvez cliquer sur Icône Plus. Créer un schéma dans le menu déroulant pour créer un nouveau schéma.
  7. Cliquez sur Créer un pipeline et continuer .
  8. Sur la page Source , sélectionnez les tables à ingérer.
  9. Cliquez sur Enregistrer et continuer .
  10. Sur la page Destination , sélectionnez un catalogue et un schéma dans lesquels charger des données. Si vous disposez des privilèges USE CATALOG et CREATE SCHEMA sur le catalogue, vous pouvez cliquer sur Icône Plus. Créer un schéma dans le menu déroulant pour créer un nouveau schéma.
  11. Cliquez sur Enregistrer et continuer .
  12. (Facultatif) Sur la page Schedules and notifications , cliquez sur Icône Plus. Créer un calendrier . Définissez la fréquence pour refresh les tables de destination.
  13. (Facultatif) Cliquez sur Icône Plus. Ajouter une notification pour définir les notifications par e-mail en cas de succès ou d'échec de l'opération du pipeline, puis cliquez sur Enregistrer et exécuter le pipeline .

Exemples​

Le fichier de définition du pipeline suivant ingère toutes les tables actuelles et futures à l’échelle du compte à partir d’un compte publicitaire :

YAML
resources:
  pipelines:
    pipeline_reddit_ads:
      name: <pipeline-name>
      catalog: <destination-catalog>
      target: <destination-schema>
      ingestion_definition:
        connection_name: <connection-name>
        objects:
          - schema:
              source_schema: <ad-account-id>
              destination_catalog: <destination-catalog>
              destination_schema: <destination-schema>
              connector_options:
                reddit_ads_options:
                  sync_start_date: <sync-start-date>
                  lookback_window_days: <lookback-window-days>

Le fichier de définition de pipeline suivant sélectionne des tables spécifiques d'un compte :

YAML
resources:
  pipelines:
    pipeline_reddit_ads:
      name: <pipeline-name>
      catalog: <destination-catalog>
      target: <destination-schema>
      ingestion_definition:
        connection_name: <connection-name>
        objects:
          - table:
              source_schema: default
              source_table: ad_account
              destination_catalog: <destination-catalog>
              destination_schema: <destination-schema>
          - table:
              source_schema: <ad-account-id>
              source_table: campaign_report
              destination_catalog: <destination-catalog>
              destination_schema: <destination-schema>
              destination_table: <destination-table>
              connector_options:
                reddit_ads_options:
                  sync_start_date: <sync-start-date>
                  lookback_window_days: <lookback-window-days>

Voici un exemple de fichier de définition de Job :

YAML
resources:
  jobs:
    reddit_ads_dab_job:
      name: reddit_ads_dab_job
      trigger:
        periodic:
          interval: 1
          unit: DAYS
      email_notifications:
        on_failure:
          - <email-address>
      tasks:
        - task_key: refresh_pipeline
          pipeline_task:
            pipeline_id: ${resources.pipelines.pipeline_reddit_ads.id}

Rapports personnalisés​

En plus des tables prédéfinies, vous pouvez définir un rapport personnalisé qui vous permet de choisir les dimensions de répartition et les champs de métrique exacts que vous souhaitez. Définissez source_table sur custom_report et fournissez la définition du rapport sous connector_options.reddit_ads_options.custom_report_options. Le nom destination_table est requis pour les rapports personnalisés.

  • breakdowns : les dimensions à regrouper, par exemple CAMPAIGN_ID, DATE, COUNTRY. Vous devez inclure au moins une dimension temporelle – DATE ou HOUR – qui devient le curseur incrémentiel de la table.
  • fields : Les champs de métrique à sélectionner, par exemple IMPRESSIONS, CLICKS, SPEND.

Pour les répartitions et les champs pris en charge, consultez Répartitions et champs de rapport personnalisés.

YAML
resources:
  pipelines:
    pipeline_reddit_ads_custom:
      name: <pipeline-name>
      catalog: <destination-catalog>
      target: <destination-schema>
      ingestion_definition:
        connection_name: <connection-name>
        objects:
          - table:
              source_schema: <ad-account-id>
              source_table: custom_report
              destination_catalog: <destination-catalog>
              destination_schema: <destination-schema>
              destination_table: my_ad_group_custom_report
              connector_options:
                reddit_ads_options:
                  sync_start_date: <sync-start-date>
                  lookback_window_days: 30
                  custom_report_options:
                    breakdowns:
                      - AD_GROUP_ID
                      - DATE
                    fields:
                      - IMPRESSIONS
                      - CLICKS
                      - SPEND
                      - CTR

Modèles courants​

Pour les configurations de pipeline avancées, consultez Modèles courants pour les pipelines d'ingestion gérés.

Étapes suivantes​

start, planifiez et configurez des alertes sur votre pipeline. Consultez les Tâches de maintenance courantes du pipeline.

Ressources supplémentaires​

Sur cette page