Documentazione Experience Platform Guida ai connettori di origini

Ultimate

Crea una connessione Source Google PubSub utilizzando l'API del servizio Flusso

Ultimo aggiornamento: 10 giugno 2025

Argomenti:

Creato per:

Sviluppatore

IMPORTANTE

L'origine Google PubSub è disponibile nel catalogo delle origini per gli utenti che hanno acquistato Real-Time Customer Data Platform Ultimate.

Questo tutorial illustra i passaggi necessari per connettere Google PubSub (di seguito "PubSub") ad Experience Platform, utilizzando Flow Service API.

Introduzione

Questa guida richiede una buona conoscenza dei seguenti componenti di Adobe Experience Platform:

Origini: Experience Platform consente di acquisire dati da varie origini e allo stesso tempo di strutturare, etichettare e migliorare i dati in arrivo tramite i servizi Experience Platform.
Sandbox: Experience Platform fornisce sandbox virtuali che suddividono una singola istanza Experience Platform in ambienti virtuali separati, utili per le attività di sviluppo e aggiornamento delle applicazioni di esperienza digitale.

Le sezioni seguenti forniscono informazioni aggiuntive che è necessario conoscere per connettere correttamente PubSub ad Experience Platform utilizzando l'API Flow Service.

Raccogli le credenziali richieste

Per connettere l'account PubSub a Flow Service, è necessario fornire i valori per le proprietà di connessione descritte di seguito. Per ulteriori informazioni sull'autenticazione e sulla configurazione dei prerequisiti, leggere la PubSub source panoramica.

Credenziali	Descrizione
`projectId`	ID progetto richiesto per autenticare PubSub.
`credentials`	Credenziali necessarie per autenticare PubSub. Assicurati di inserire il file JSON completo dopo aver rimosso gli spazi vuoti dalle credenziali.
`connectionSpec.id`	La specifica di connessione restituisce le proprietà del connettore di origine, incluse le specifiche di autenticazione relative alla creazione delle connessioni di base e di destinazione di origine. ID della specifica di connessione PubSub: `70116022-a743-464a-bbfe-e226a7f8210c`.

Credenziali	Descrizione
`credentials`	Credenziali necessarie per autenticare PubSub. Assicurati di inserire il file JSON completo dopo aver rimosso gli spazi vuoti dalle credenziali.
`topicName`	Nome della risorsa che rappresenta un feed di messaggi. È necessario specificare un nome di argomento se si desidera fornire l'accesso a un flusso di dati specifico nell'origine PubSub. Il formato del nome argomento è: `projects/{PROJECT_ID}/topics/{TOPIC_ID}`.
`subscriptionName`	Nome dell'abbonamento PubSub. In PubSub, gli abbonamenti consentono di ricevere messaggi, sottoscrivendo l'argomento in cui i messaggi sono stati pubblicati. Nota: è possibile utilizzare una singola sottoscrizione PubSub per un solo flusso di dati. Per creare più flussi di dati, devi disporre di più abbonamenti. Formato del nome della sottoscrizione: `projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_ID}`.
`connectionSpec.id`	La specifica di connessione restituisce le proprietà del connettore di origine, incluse le specifiche di autenticazione relative alla creazione delle connessioni di base e di destinazione di origine. ID della specifica di connessione PubSub: `70116022-a743-464a-bbfe-e226a7f8210c`.

Per ulteriori informazioni su questi valori, leggere questo documento di PubSub autenticazione. Per utilizzare l'autenticazione basata su account di servizio, leggere questa PubSub guida sulla creazione di account di servizio per i passaggi relativi alla generazione delle credenziali.

SUGGERIMENTO

Se utilizzi l’autenticazione basata sull’account del servizio, assicurati di aver concesso un accesso utente sufficiente all’account del servizio e di non inserire spazi vuoti aggiuntivi nel JSON quando copi e incolla le credenziali.

Utilizzo delle API di Experience Platform

Per informazioni su come effettuare correttamente chiamate alle API di Experience Platform, consulta la guida introduttiva alle API di Experience Platform.

Creare una connessione di base

SUGGERIMENTO

Una volta creata, non è possibile modificare il tipo di autenticazione di una connessione di base Google PubSub. Per modificare il tipo di autenticazione, è necessario creare una nuova connessione di base.

Il primo passaggio nella creazione di una connessione di origine consiste nell'autenticare l'origine PubSub e generare un ID connessione di base. Un ID di connessione di base consente di esplorare e navigare tra i file dall’interno dell’origine e identificare elementi specifici da acquisire, incluse informazioni relative ai tipi di dati e ai formati.

Per creare un ID connessione di base, eseguire una richiesta POST all'endpoint /connections fornendo le credenziali di autenticazione PubSub come parte dei parametri della richiesta.

L'origine PubSub consente di specificare il tipo di accesso da consentire durante l'autenticazione. È possibile impostare l'account in modo che disponga dell'accesso root o limitare l'accesso a un particolare argomento PubSub e a una sottoscrizione specifica.

NOTA

Le entità (ruoli) assegnate a un progetto PubSub vengono ereditate in tutti gli argomenti e le sottoscrizioni creati all'interno di un progetto PubSub. Se si desidera che un'entità principale (ruolo) abbia accesso a un argomento specifico, è necessario aggiungere anche tale entità principale (ruolo) alla sottoscrizione corrispondente dell'argomento. Per ulteriori informazioni, leggere la PubSub documentazione sul controllo degli accessi.

Formato API

POST /connections

Per creare una connessione di base con l'autenticazione basata su progetto, effettuare una richiesta POST all'endpoint /connections e fornire projectId e credentials nel corpo della richiesta.

Richiesta

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": "Google PubSub connection",
      "description": "Google PubSub connection",
      "auth": {
          "specName": "Project Based Authentication",
          "params": {
              "projectId": "{PROJECT_ID}",
              "credentials": "{CREDENTIALS}"
          }
      },
      "connectionSpec": {
          "id": "70116022-a743-464a-bbfe-e226a7f8210c",
          "version": "1.0"
      }
  }'

Proprietà

Descrizione

auth.params.projectId

ID progetto richiesto per autenticare PubSub.

auth.params.credentials

Credenziali o chiave necessarie per autenticare PubSub.

connectionSpec.id

ID della specifica di connessione PubSub: 70116022-a743-464a-bbfe-e226a7f8210c.

Risposta

In caso di esito positivo, la risposta restituisce i dettagli della connessione appena creata, incluso il relativo identificatore univoco (id). Questo ID connessione di base è richiesto nel passaggio successivo per creare una connessione sorgente.

{
    "id": "4cb0c374-d3bb-4557-b139-5712880adc55",
    "etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}

Per creare una connessione di base con autenticazione basata su argomento e su sottoscrizione, effettuare una richiesta POST all'endpoint /connections e fornire credentials, topicName e subscriptionName nel corpo della richiesta.

Richiesta

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": "Google PubSub connection",
      "description": "Google PubSub connection",
      "auth": {
          "specName": "Topic & Subscription Based Authentication",
          "params": {
              "credentials": "{CREDENTIALS}",
              "topicName": "projects/{PROJECT_ID}/topics/{TOPIC_ID}",
              "subscriptionName": "projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_ID}"
          }
      },
      "connectionSpec": {
          "id": "70116022-a743-464a-bbfe-e226a7f8210c",
          "version": "1.0"
      }
  }'

Proprietà

Descrizione

auth.params.credentials

Credenziali o chiave necessarie per autenticare PubSub.

auth.params.topicName

Coppia ID progetto e ID argomento per l'origine PubSub a cui si desidera fornire l'accesso.

auth.params.subscriptionName

La coppia ID progetto e ID sottoscrizione per l'origine PubSub a cui si desidera fornire l'accesso.

connectionSpec.id

ID della specifica di connessione PubSub: 70116022-a743-464a-bbfe-e226a7f8210c.

Risposta

In caso di esito positivo, la risposta restituisce i dettagli della connessione appena creata, incluso il relativo identificatore univoco (id). Questo ID connessione di base è richiesto nel passaggio successivo per creare una connessione sorgente.

{
    "id": "4cb0c374-d3bb-4557-b139-5712880adc55",
    "etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}

Creare una connessione sorgente

Una connessione di origine crea e gestisce la connessione all’origine esterna da cui vengono acquisiti i dati. Una connessione di origine è costituita da informazioni quali origine dati, formato dati e un ID di connessione di origine necessari per creare un flusso di dati. Un'istanza della connessione di origine è specifica di un tenant e di un'organizzazione.

Per creare una connessione di origine, eseguire una richiesta POST all'endpoint /sourceConnections dell'API Flow Service.

Formato API

POST /sourceConnections

Richiesta

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": "Google PubSub source connection",
      "description": "A source connection for Google PubSub",
      "baseConnectionId": "4cb0c374-d3bb-4557-b139-5712880adc55",
      "connectionSpec": {
          "id": "70116022-a743-464a-bbfe-e226a7f8210c",
          "version": "1.0"
      },
      "data": {
          "format": "json"
      },
      "params": {
          "topicName": "projects/{PROJECT_ID}/topics/{TOPIC_ID}",
          "subscriptionName": "projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_ID}",
          "dataType": "raw"
      }
  }'

Proprietà

Descrizione

name

Nome della connessione di origine. Assicurati che il nome della connessione sorgente sia descrittivo, in quanto può essere utilizzato per cercare informazioni sulla connessione sorgente.

description

Valore facoltativo che è possibile fornire per includere ulteriori informazioni sulla connessione di origine.

baseConnectionId

ID della connessione di base dell'origine PubSub generato nel passaggio precedente.

connectionSpec.id

ID della specifica di connessione fissa per PubSub. ID: 70116022-a743-464a-bbfe-e226a7f8210c

data.format

Formato dei dati PubSub che si desidera acquisire. Attualmente, l'unico formato di dati supportato è json.

params.topicName

Il nome dell'argomento PubSub. In PubSub un argomento è una risorsa denominata che rappresenta un feed di messaggi.

params.subscriptionName

Il nome della sottoscrizione che corrisponde a un determinato argomento. In PubSub, gli abbonamenti consentono di leggere i messaggi da un argomento. È possibile assegnare una o più sottoscrizioni a un singolo argomento.

params.dataType

Questo parametro definisce il tipo di dati che viene acquisito. I tipi di dati supportati sono: raw e xdm.

Risposta

In caso di esito positivo, la risposta restituisce l'identificatore univoco (id) della connessione di origine appena creata. Questo ID è richiesto nell’esercitazione successiva per creare un flusso di dati.

{
    "id": "e96d6135-4b50-446e-922c-6dd66672b6b2",
    "etag": "\"66013508-0000-0200-0000-5f6e2ae70000\""
}

NOTE

Dopo aver creato o aggiornato un flusso di dati in streaming, è necessaria una breve pausa di 5 minuti nell’acquisizione dei dati per evitare potenziali istanze di perdita o perdita di dati.

Passaggi successivi

Seguendo questa esercitazione, hai creato una connessione sorgente PubSub utilizzando l'API Flow Service. Puoi utilizzare questo ID connessione di origine nella prossima esercitazione per creare un flusso di dati in streaming utilizzando l' Flow Service API.

recommendation-more-help