El Azure Event Hubs La fuente de está disponible en el catálogo de fuentes de para los usuarios que han adquirido Real-time Customer Data Platform Ultimate.
Este tutorial proporciona los pasos para crear una Azure Event Hubs (en lo sucesivo, "Event Hubs") al Experience Platform, utilizando Flow Service API.
Esta guía requiere una comprensión práctica de los siguientes componentes de Adobe Experience Platform:
Las secciones siguientes proporcionan información adicional que deberá conocer para conectarse correctamente Event Hubs a Platform mediante el Flow Service API.
Para que Flow Service para conectarse con su Event Hubs En su cuenta de, debe proporcionar valores para las siguientes propiedades de conexión:
Credencial | Descripción |
---|---|
sasKeyName |
Nombre de la regla de autorización, que también se conoce como nombre de clave SAS. |
sasKey |
La clave principal del Event Hubs namespace. El sasPolicy que el sasKey corresponde a debe tener manage derechos configurados para el Event Hubs lista que se va a rellenar. |
namespace |
El área de nombres del Event Hubs está accediendo a. Un Event Hubs el espacio de nombres proporciona un contenedor de ámbito único, en el que puede crear uno o más Event Hubs. |
connectionSpec.id |
La especificación de conexión devuelve las propiedades del conector de origen, incluidas las especificaciones de autenticación relacionadas con la creación de las conexiones base y origen. El Event Hubs ID de especificación de conexión: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
Credencial | Descripción |
---|---|
sasKeyName |
Nombre de la regla de autorización, que también se conoce como nombre de clave SAS. |
sasKey |
La clave principal del Event Hubs namespace. El sasPolicy que el sasKey corresponde a debe tener manage derechos configurados para el Event Hubs lista que se va a rellenar. |
namespace |
El área de nombres del Event Hubs está accediendo a. Un Event Hubs el espacio de nombres proporciona un contenedor de ámbito único, en el que puede crear uno o más Event Hubs. |
eventHubName |
El nombre de su Event Hubs origen. |
connectionSpec.id |
La especificación de conexión devuelve las propiedades del conector de origen, incluidas las especificaciones de autenticación relacionadas con la creación de las conexiones base y origen. El Event Hubs ID de especificación de conexión: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
Para obtener más información, consulte este documento de Event Hubs.
Para obtener información sobre cómo realizar llamadas correctamente a las API de Platform, consulte la guía de introducción a las API de Platform.
Una vez creado, no se puede cambiar el tipo de autenticación de una Event Hubs conexión base. Para cambiar el tipo de autenticación, debe crear una nueva conexión base.
El primer paso para crear una conexión de origen es autenticar su Event Hubs y generar un ID de conexión base. Un ID de conexión base le permite explorar y navegar por archivos desde el origen e identificar elementos específicos que desee introducir, incluida información sobre sus tipos de datos y formatos.
Para crear un ID de conexión base, realice una solicitud de POST al /connections
extremo al proporcionar su Event Hubs credenciales de autenticación como parte de los parámetros de solicitud.
Formato de API
POST /connections
Para crear una cuenta con autenticación estándar, realice una solicitud de POST al /connections
al proporcionar valores para su sasKeyName
, sasKey
, y namespace
.
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: {ORG_ID}' \
-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"
}
}'
Propiedad | Descripción |
---|---|
auth.params.sasKeyName |
Nombre de la regla de autorización, que también se conoce como nombre de clave SAS. |
auth.params.sasKey |
La firma de acceso compartido generada. |
auth.params.namespace |
El área de nombres del Event Hubs está accediendo a. |
connectionSpec.id |
El Event Hubs ID de especificación de conexión: bf9f5905-92b7-48bf-bf20-455bc6b60a4e |
Una respuesta correcta devuelve detalles de la conexión base recién creada, incluido su identificador único (id
). Este ID de conexión es necesario en el siguiente paso para crear una conexión de origen.
{
"id": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
"etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}
Para crear una cuenta con autenticación SAS, realice una solicitud de POST al /connections
al proporcionar valores para su sasKeyName
, sasKey
,namespace
, y eventHubName
.
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: {ORG_ID}' \
-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}",
"eventHubName": "{EVENT_HUB_NAME}
}
},
"connectionSpec": {
"id": "bf9f5905-92b7-48bf-bf20-455bc6b60a4e",
"version": "1.0"
}
}'
Propiedad | Descripción |
---|---|
auth.params.sasKeyName |
Nombre de la regla de autorización, que también se conoce como nombre de clave SAS. |
auth.params.sasKey |
La firma de acceso compartido generada. |
auth.params.namespace |
El área de nombres del Event Hubs está accediendo a. |
params.eventHubName |
El nombre de su Event Hubs origen. |
connectionSpec.id |
El Event Hubs ID de especificación de conexión: bf9f5905-92b7-48bf-bf20-455bc6b60a4e |
Una respuesta correcta devuelve detalles de la conexión base recién creada, incluido su identificador único (id
). Este ID de conexión es necesario en el siguiente paso para crear una conexión de origen.
{
"id": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
"etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}
Un Event Hubs el grupo de consumidores solo se puede utilizar para un único flujo en un momento determinado.
Una conexión de origen crea y administra la conexión con el origen externo desde el que se incorporan los datos. Una conexión de origen consta de información como el origen de datos, el formato de datos y un ID de conexión de origen necesario para crear un flujo de datos. Una instancia de conexión de origen es específica de un inquilino y una organización.
Para crear una conexión de origen, realice una solicitud de POST al /sourceConnections
punto final del Flow Service API.
Formato de API
POST /sourceConnections
Solicitud
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: {ORG_ID}' \
-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": "{EVENT_HUB_NAME}",
"dataType": "raw",
"reset": "latest",
"consumerGroup": "{CONSUMER_GROUP}"
}
}'
Propiedad | Descripción |
---|---|
name |
Nombre de la conexión de origen. Asegúrese de que el nombre de la conexión de origen sea descriptivo, ya que puede utilizarlo para buscar información sobre la conexión de origen. |
description |
Un valor opcional que puede proporcionar para incluir más información sobre la conexión de origen. |
baseConnectionId |
El ID de conexión de su Event Hubs origen que se generó en el paso anterior. |
connectionSpec.id |
Identificador de especificación de conexión fija para Event Hubs. Este ID es: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
data.format |
El formato del Event Hubs datos que desea introducir. Actualmente, el único formato de datos admitido es json . |
params.eventHubName |
El nombre de su Event Hubs origen. |
params.dataType |
Este parámetro define el tipo de datos que se están introduciendo. Los tipos de datos admitidos son: raw y xdm . |
params.reset |
Este parámetro define cómo se leerán los datos. Uso latest para empezar a leer los datos más recientes, y utilice earliest para comenzar a leer los primeros datos disponibles en la secuencia. Este parámetro es opcional y el valor predeterminado es earliest si no se proporciona. |
params.consumerGroup |
Mecanismo de publicación o suscripción que se utilizará para Event Hubs. Este parámetro es opcional y el valor predeterminado es $Default si no se proporciona. Consulte esta sección Event Hubs guía para consumidores de eventos para obtener más información. Nota: Un Event Hubs el grupo de consumidores solo se puede utilizar para un único flujo en un momento determinado. |
Al seguir este tutorial, ha creado un Event Hubs conexión de origen mediante Flow Service API. Puede utilizar este ID de conexión de origen en el siguiente tutorial para lo siguiente crear un flujo de datos de flujo continuo utilizando Flow Service API.