Trigger di Cloud Pub/Sub

Annuncio: Application Integration è ora disponibile per il tuo progetto Google Cloud. Ora puoi utilizzare sia Apigee Integration che Application Integration all'interno dello stesso progetto Google Cloud. Scopri di più

Il trigger di Cloud Pub/Sub consente di eseguire l'integrazione in base agli eventi nel tuo middleware Pub/Sub.

Con questo trigger puoi eseguire un'integrazione ogni volta che un publisher scrive un messaggio nell'argomento scelto. Quando questo trigger viene eseguito, scrive anche il messaggio pubblicato nella variabile di output CloudPubSubMessage. In base ai tuoi requisiti, puoi utilizzare questa variabile nei trigger o nelle attività downstream.

Nota: l'argomento configurato per il trigger deve essere disponibile nello stesso progetto Google Cloud dell'integrazione. Apigee non supporta le esecuzioni di trigger di Cloud Pub/Sub in diversi progetti Google Cloud.

Prima di iniziare

Assicurati di eseguire le attività seguenti nel tuo progetto Google Cloud prima di configurare il trigger di Cloud Pub/Sub.

• Assegna i seguenti ruoli IAM al tuo account di servizio predefinito ([e-mail]):
• Conferma di avere un argomento Pub/Sub. Per creare un nuovo argomento Pub/Sub:
  1. Vai alla pagina degli argomenti Pub/Sub nella console Cloud.

     Vai alla pagina degli argomenti Pub/Sub

  2. Fai clic su Crea un argomento.
  3. Nel campo ID argomento, fornisci un nome univoco per l'argomento.
  4. Fai clic su Salva.
  Nota: non è necessario creare una sottoscrizione affinché l'attivatore funzioni. Apigee crea automaticamente una sottoscrizione per un argomento. Puoi visualizzare tutte le tue sottoscrizioni nella pagina della sottoscrizione Pub/Sub.

Per saperne di più sulla gestione dell'accesso utilizzando i ruoli IAM, consulta Controllo dell'accesso.

Per informazioni sulla concessione dei ruoli alle entità, vedi Concessione, modifica e revoca dell'accesso.

Aggiungi un trigger di Cloud Pub/Sub

Per aggiungere un trigger di Cloud Pub/Sub a un'integrazione nuova o esistente, segui questi passaggi:

1. Nell'interfaccia utente di Apigee, seleziona la tua organizzazione Apigee.
2. Fai clic su Sviluppa > Integrazioni.
3. Seleziona un'integrazione esistente o creane una nuova facendo clic su Crea integrazione.

   Se stai creando una nuova integrazione:

   1. Inserisci un nome e una descrizione nella finestra di dialogo Crea integrazione.
   2. Seleziona una regione per l'integrazione dall'elenco delle regioni supportate.
   3. Fai clic su Crea.

   In questo modo viene aperta l'integrazione nel designer dell'integrazione.

4. Nella barra di navigazione del designer dell'integrazione, fai clic su + Aggiungi un'attività/un attivatore > Trigger per visualizzare l'elenco dei trigger disponibili.
5. Fai clic sull'elemento trigger di Cloud Pub/Sub e posizionalo nel designer.

configura un trigger di Cloud Pub/Sub

Fai clic sull'elemento trigger di Cloud Pub/Sub nell'editor di integrazione per visualizzare il riquadro di configurazione del trigger, quindi svolgi le attività seguenti:

Specifica l'argomento che il trigger deve rimanere in ascolto nel campo Argomento Pub/Sub nel seguente formato:

projects/PROJECT_ID/topics/TOPIC_ID

Per visualizzare tutti gli argomenti disponibili nel tuo progetto Google Cloud, consulta la colonna Nome argomento in Argomenti.

Sostituisci quanto segue:

• PROJECT_ID: il progetto Google Cloud in cui viene creato l'argomento.
• TOPIC_ID: l'ID del tuo argomento Pub/Sub.

Output trigger

Per ogni evento, il trigger di Cloud Pub/Sub genera una variabile di output CloudPubSubMessage che puoi utilizzare nelle attività downstream. La variabile è in formato JSON e ha la struttura PubsubMessage.

Considerazioni

• La dimensione massima di un messaggio Pub/Sub è 10 MB. Per comprendere tutte le limitazioni di Pub/Sub, vedi Quote e limiti di Pub/Sub.
• È possibile che Pub/Sub scriva lo stesso messaggio più di una volta in un argomento. Per comprendere questo comportamento di Pub/Sub, consulta Distribuzione At-Least-Once. Di conseguenza, devi progettare l'integrazione in modo che sia idempotente, in modo che non consenta la scrittura più di una volta di un messaggio in un argomento.

  Il campo message_id nell'intestazione del messaggio identifica in modo univoco un messaggio Pub/Sub.

• Se annulli la pubblicazione di un'integrazione, la sottoscrizione Pub/Sub non viene eliminata per evitare la perdita dei messaggi. Tuttavia, se elimini la versione pubblicata o tutte le versioni di integrazione di un'integrazione, viene eliminata anche la sottoscrizione Pub/Sub.