Créez un Azure Event Hubs connexion source à l’aide de la fonction Flow Service API

Ce tutoriel vous guide tout au long des étapes pour vous connecter. Azure Event Hubs (ci-après dénommés "Event Hubs") à l’Experience Platform, à l’aide de la variable Flow Service API.

Prise en main

Ce guide nécessite une compréhension professionnelle des composants suivants d’Adobe Experience Platform :

  • Sources: Experience Platform permet d’ingérer des données provenant de diverses sources tout en vous permettant de structurer, d’étiqueter et d’améliorer les données entrantes à l’aide de Platform services.
  • Environnements de test : Experience Platform fournit des environnements de test virtuels qui divisent une instance Platform unique en environnements virtuels distincts pour favoriser le développement et l’évolution d’applications d’expérience numérique.

Les sections suivantes apportent des informations supplémentaires dont vous aurez besoin pour vous connecter. Event Hubs vers Platform à l’aide de Flow Service API.

Collecte des informations d’identification requises

Pour Flow Service pour vous connecter à Event Hubs , vous devez fournir des valeurs pour les propriétés de connexion suivantes :

Credential Description
sasKeyName Nom de la règle d’autorisation, également connu sous le nom de clé SAS.
sasKey La clé Principale de la variable Event Hubs espace de noms. Le sasPolicy que la variable sasKey correspond à manage les droits configurés pour Event Hubs liste à renseigner.
namespace L’espace de noms de la variable Event Hubs vous y accédez. Un Event Hubs L’espace de noms fournit un conteneur d’étendue unique, dans lequel vous pouvez créer un ou plusieurs Event Hubs.
connectionSpec.id La spécification de connexion renvoie les propriétés du connecteur d’une source, y compris les spécifications d’authentification liées à la création des connexions base et source. Le Event Hubs l’identifiant de spécification de connexion est : bf9f5905-92b7-48bf-bf20-455bc6b60a4e.

Pour plus d’informations sur ces valeurs, reportez-vous à la section ce document Événements Hub.

Utilisation des API Platform

Pour plus d’informations sur la manière d’effectuer avec succès des appels vers les API Platform, consultez le guide sur Prise en main des API Platform.

Création d’une connexion de base

La première étape de la création d’une connexion source consiste à authentifier votre Event Hubs source et générer un identifiant de connexion de base. Un identifiant de connexion de base vous permet d’explorer et de parcourir les fichiers de votre source et d’identifier les éléments spécifiques à ingérer, y compris des informations concernant leurs types et formats de données.

Pour créer un identifiant de connexion de base, envoyez une requête de POST au /connections point de terminaison lors de la fourniture de Event Hubs informations d’identification d’authentification dans le cadre des paramètres de requête.

Format d’API

POST /connections

Requête

curl -X POST \
    'https://platform.adobe.io/data/foundation/flowservice/connections' \
    -H 'Authorization: Bearer {ACCESS_TOKEN}' \
    -H 'x-api-key: {API_KEY}' \
    -H 'x-gw-ims-org-id: {IMS_ORG}' \
    -H 'x-sandbox-name: {SANDBOX_NAME}' \
    -H 'Content-Type: application/json' \
    -d '{
        "name": "Azure Event Hubs connection",
        "description": "Connector for Azure Event Hubs",
        "auth": {
            "specName": "Azure EventHub authentication credentials",
            "params": {
                "sasKeyName": "{SAS_KEY_NAME}",
                "sasKey": "{SAS_KEY}",
                "namespace": "{NAMESPACE}"
            }
        },
        "connectionSpec": {
            "id": "bf9f5905-92b7-48bf-bf20-455bc6b60a4e",
            "version": "1.0"
        }
    }'
Propriété Description
auth.params.sasKeyName Nom de la règle d’autorisation, également connu sous le nom de clé SAS.
auth.params.sasKey Signature d’accès partagé générée.
auth.params.namespace L’espace de noms de la variable Event Hubs vous y accédez.
connectionSpec.id Le Event Hubs l’identifiant de spécification de connexion est : bf9f5905-92b7-48bf-bf20-455bc6b60a4e

Réponse

Une réponse réussie renvoie les détails de la connexion de base que vous venez de créer, y compris son identifiant unique (id). Cet identifiant de connexion est requis à l’étape suivante pour créer une connexion source.

{
    "id": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
    "etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}

Création d’une connexion source

Une connexion source crée et gère la connexion à la source externe à partir de laquelle les données sont ingérées. Une connexion source se compose d’informations telles que la source de données, le format de données et un identifiant de connexion source nécessaires à la création d’un flux de données. Une instance de connexion source est spécifique à un client et à une organisation IMS.

Pour créer une connexion source, envoyez une requête de POST au /sourceConnections point d’entrée du Flow Service API.

Format d’API

POST /sourceConnections

Requête

curl -X POST \
    'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
    -H 'authorization: Bearer {ACCESS_TOKEN}' \
    -H 'content-type: application/json' \
    -H 'x-api-key: {API_KEY}' \
    -H 'x-gw-ims-org-id: {IMS_Org}' \
    -H 'x-sandbox-name: {SANDBOX_NAME}' \
    -d '{
        "name": "Azure Event Hubs source connection",
        "description": "A source connection for Azure Event Hubs",
        "baseConnectionId": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
        "connectionSpec": {
            "id": "bf9f5905-92b7-48bf-bf20-455bc6b60a4e",
            "version": "1.0"
        },
        "data": {
            "format": "json"
        },
        "params": {
            "eventHubName": "{EVENTHUB_NAME}",
            "dataType": "raw",
            "reset": "latest",
            "consumerGroup": "{CONSUMER_GROUP}"
        }
    }'
Propriété Description
name Nom de la connexion source. Assurez-vous que le nom de votre connexion source est descriptif, car vous pouvez l’utiliser pour rechercher des informations sur votre connexion source.
description Valeur facultative que vous pouvez fournir pour inclure plus d’informations sur votre connexion source.
baseConnectionId L’identifiant de connexion de votre Event Hubs source générée à l’étape précédente.
connectionSpec.id L’identifiant de spécification de connexion fixe pour Event Hubs. Cet identifiant est : bf9f5905-92b7-48bf-bf20-455bc6b60a4e.
data.format Le format de la variable Event Hubs données que vous souhaitez ingérer. Actuellement, le seul format de données pris en charge est json.
params.eventHubName Le nom de votre Event Hubs source.
params.dataType Ce paramètre définit le type des données ingérées. Les types de données pris en charge sont les suivants : raw et xdm.
params.reset Ce paramètre définit la manière dont les données seront lues. Utilisation latest pour commencer la lecture à partir des données les plus récentes et utiliser earliest pour commencer la lecture à partir des premières données disponibles dans le flux. Ce paramètre est facultatif et la valeur par défaut est earliest si non fourni.
params.consumerGroup Le mécanisme de publication ou d’abonnement à utiliser pour Event Hubs. Ce paramètre est facultatif et la valeur par défaut est $Default si non fourni. Consultez cette section Event Hubs guide sur les consommateurs d’événements pour plus d’informations.

Étapes suivantes

En suivant ce tutoriel, vous avez créé une Event Hubs connexion source à l’aide de la fonction Flow Service API. Vous pouvez utiliser cet identifiant de connexion source dans le tutoriel suivant pour créez un flux de données en continu à l’aide de la fonction Flow Service API.

Sur cette page