View a markdown version of this page

Creazione di una EventBridge pipa Amazon - Amazon EventBridge
Specificare un'origineConfigurazione dei filtriDefinizione dell'arricchimentoConfigurazione di una destinazioneConfigurazione delle impostazioni della pipeConvalida dei parametri di configurazione

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Creazione di una EventBridge pipa Amazon

EventBridge Pipes consente di creare integrazioni punto a punto tra sorgenti e destinazioni, incluse trasformazioni e arricchimenti avanzati degli eventi.

Per creare una EventBridge pipe, effettuate le seguenti operazioni:

  1. Specificare un'origine

  2. Configurazione dei filtri di eventi (facoltativo)

  3. Definizione dell'arricchimento degli eventi (facoltativo)

  4. Configurazione di una destinazione

  5. Configurazione delle impostazioni della pipe

Per configurare rapidamente una tubazione di esempio, vedereGuida introduttiva: crea una EventBridge pipa Amazon. Questo argomento CloudFormation illustra la distribuzione di una pipe e delle risorse associate e illustra una panoramica delle funzionalità di una pipe.

Per informazioni su come creare una pipe utilizzando la AWS CLI, vedi create-pipe nel CLI Command Reference. AWS

Specificare un'origine

Per iniziare, specifica l'origine da cui la pipe deve ricevere eventi.

Per specificare l''origine di una pipe utilizzando la console

  1. Apri la console Amazon all'indirizzo. EventBridge https://console.aws.amazon.com/events/

  2. Nel riquadro di navigazione, scegli Pipe.

  3. Scegli Crea pipe.

  4. Immetti un nome per la pipe.

  5. (Facoltativo) Aggiungi una descrizione per la pipe.

  6. Nella scheda Costruisci pipe, in Origine, scegli il tipo di origine da specificare per la pipe e configura l'origine.

    Le proprietà di configurazione differiscono in base al tipo di origine che scegli:

    Confluent
    Per configurare uno stream Confluent Cloud come sorgente, utilizzando la console

    1. Per Source, scegli Confluent Cloud.

    2. In Server di bootstrap, immetti gli indirizzi della coppia host:port dei tuoi broker.

    3. In Nome dell'argomento, immetti il nome dell'argomento che la pipe leggerà.

    4. (Facoltativo) In VPC, scegli il VPC da utilizzare. In Sottoreti VPC, scegli le sottoreti. In Gruppi di sicurezza VPC, scegli i gruppi di sicurezza.

    5. Per l'autenticazione: opzionale, attiva Usa l'autenticazione ed esegui le seguenti operazioni:

      1. In Metodo di autenticazione, scegli il tipo di autenticazione.

      2. In Chiave segreta, scegli la chiave segreta.

      Per ulteriori informazioni, consulta le risorse Authenticate to Confluent Cloud nella documentazione di Confluent.

    6. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Posizione di partenza, scegli una delle seguenti opzioni:

        • Più recente: inizia a leggere il flusso con il record più recente nella partizione.

        • Orizzonte di taglio: inizia a leggere il flusso con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.

      2. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 100.

      3. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

    DynamoDB

    1. In Origine, scegli Dynamo DB.

    2. In Flusso DynamoDB, scegli il flusso da utilizzare come origine.

    3. In Posizione di partenza, scegli una delle seguenti opzioni:

      • Più recente: inizia a leggere il flusso con il record più recente nella partizione.

      • Orizzonte di taglio: inizia a leggere il flusso con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.

    4. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 10.

      2. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

      3. In Batch simultanei per partizione (facoltativo), immetti il numero di batch della stessa partizione che possono essere letti contemporaneamente.

      4. In In caso di errore parziale dell'articolo di un batch, scegli quanto segue:

        • AUTOMATIC_BISECT: dimezza ogni batch e riprova ogni metà fino a quando tutti i record non risultano elaborati o rimane un messaggio di errore nel batch.

        Nota

        Se non scegli AUTOMATIC_BISECT, è possibile che vengano restituiti specifici record non riusciti e solo per quelli viene effettuato un nuovo tentativo.

    Kinesis
    Per configurare un'origine Kinesis utilizzando la console

    1. In Origine, scegli Kinesis.

    2. In Flusso Kinesis, scegli il flusso da utilizzare come origine.

    3. In Posizione di partenza, scegli una delle seguenti opzioni:

      • Più recente: inizia a leggere il flusso con il record più recente nella partizione.

      • Orizzonte di taglio: inizia a leggere il flusso con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.

      • Al timestamp: inizia a leggere il flusso a partire dalla data specificata. In Timestamp, inserisci una data e un'ora utilizzando il formato hh:mm:ss. YYYY/MM/DD

    4. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 10.

      2. (Facoltativo) In Finestra batch (facoltativo), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

      3. In Batch simultanei per partizione (facoltativo), immetti il numero di batch della stessa partizione che possono essere letti contemporaneamente.

      4. In In caso di errore parziale dell'articolo di un batch, scegli quanto segue:

        • AUTOMATIC_BISECT: dimezza ogni batch e riprova ogni metà fino a quando tutti i record non risultano elaborati o rimane un messaggio di errore nel batch.

        Nota

        Se non scegli AUTOMATIC_BISECT, è possibile che vengano restituiti specifici record non riusciti e solo per quelli viene effettuato un nuovo tentativo.

    Amazon MQ
    Per configurare un'origine Amazon MQ utilizzando la console

    1. In Origine, scegli Amazon MQ.

    2. In Broker Amazon MQ, scegli il flusso da utilizzare come origine.

    3. In Nome della coda, immetti il nome della coda che la pipe leggerà.

    4. In Metodo di autenticazione, scegli BASIC_AUTH.

    5. In Chiave segreta, scegli la chiave segreta.

    6. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Dimensione del batch (facoltativo), immetti un numero massimo di messaggi per ogni batch. Il valore predefinito è 100.

      2. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

    Amazon MSK
    Per configurare un'origine Amazon MSK utilizzando la console

    1. In Origine, scegli Amazon MSK.

    2. In Cluster Amazon MSK, scegli il cluster da utilizzare.

    3. In Nome dell'argomento, immetti il nome dell'argomento che la pipe leggerà.

    4. (Facoltativo) In ID del gruppo di consumatori (facoltativo), immetti l'ID del gruppo di consumer a cui la pipe deve aderire.

    5. (Facoltativo) In Autenticazione (facoltativo), attiva Usa l'autenticazione ed esegui le seguenti operazioni:

      1. In Metodo di autenticazione, scegli il tipo che desideri.

      2. In Chiave segreta, scegli la chiave segreta.

    6. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 100.

      2. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

      3. In Posizione di partenza, scegli una delle seguenti opzioni:

        • Più recente: inizia a leggere l'argomento con il record più recente nella partizione.

        • Orizzonte di taglio: inizia a leggere l'argomento con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.

          Nota

          Orizzonte di taglio è simile a Meno recente per Apache Kafka.

    Self managed Apache Kafka
    Per configurare un'origine Apache Kafka autogestita utilizzando la console

    1. Per Source, scegli Apache Kafka. Self-managed

    2. In Server di bootstrap, immetti gli indirizzi della coppia host:port dei tuoi broker.

    3. In Nome dell'argomento, immetti il nome dell'argomento che la pipe leggerà.

    4. (Facoltativo) In VPC, scegli il VPC da utilizzare. In Sottoreti VPC, scegli le sottoreti. In Gruppi di sicurezza VPC, scegli i gruppi di sicurezza.

    5. (Facoltativo) In Autenticazione (facoltativo), attiva Usa l'autenticazione ed esegui le seguenti operazioni:

      1. In Metodo di autenticazione, scegli il tipo di autenticazione.

      2. In Chiave segreta, scegli la chiave segreta.

    6. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Posizione di partenza, scegli una delle seguenti opzioni:

        • Più recente: inizia a leggere il flusso con il record più recente nella partizione.

        • Orizzonte di taglio: inizia a leggere il flusso con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.

      2. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 100.

      3. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

    Amazon SQS
    Per configurare un'origine Amazon SQS utilizzando la console

    1. In Origine, scegli SQS.

    2. In coda SQS, scegli la coda da utilizzare.

    3. (Facoltativo) In Impostazioni aggiuntive (facoltativo), procedi come segue:

      1. In Dimensione del batch (facoltativo), immetti un numero massimo di record per ogni batch. Il valore predefinito è 100.

      2. In Finestra batch (facoltativa), immetti un numero massimo di secondi per raccogliere i record prima di procedere.

Configurazione dei filtri di eventi (facoltativo)

Puoi aggiungere filtri alla tua pipe in modo da inviare solo un sottoinsieme di eventi dall'origine alla destinazione.

Per configurare i filtri utilizzando la console

  1. Scegli Filtro.

  2. In Evento di esempio (facoltativo), vedrai un evento di esempio che puoi usare per creare il tuo modello di eventi, oppure puoi immettere il tuo evento scegliendo Inserisci il mio.

  3. In Modello di eventi, immetti il modello di eventi da utilizzare per filtrare gli eventi. Per ulteriori informazioni sulla creazione di filtri, vedere. Filtraggio degli eventi in Amazon EventBridge Pipes

    Di seguito è riportato un esempio di modello di eventi che invia solo eventi con il valore Seattle nel campo City.

    {
  "data": {
    "City": ["Seattle"]
  }
}

Ora che gli eventi vengono filtrati, puoi aggiungere un arricchimento facoltativo e un destinazione per la pipe.

Definizione dell'arricchimento degli eventi (facoltativo)

Puoi inviare i dati degli eventi per l'arricchimento a una funzione Lambda, una macchina a AWS Step Functions stati, Amazon API Gateway o una destinazione API.

Per selezionare l'arricchimento

  1. Scegli Arricchimento.

  2. In Dettagli, per Servizio, seleziona il servizio e le relative impostazioni da utilizzare per l'arricchimento.

Puoi anche trasformare i dati prima di inviarli per migliorarli.

(Facoltativo) Per definire il trasformatore di input

  1. Scegli Trasformatore di input di arricchimento (facoltativo).

  2. Per Sample events/Event Payload, scegli il tipo di evento di esempio.

  3. In Trasformatore, immetti la sintassi del trasformatore, ad esempio "Event happened at <$.detail.field>." dove <$.detail.field> è un riferimento a un campo dell'evento di esempio. Puoi anche fare doppio clic su un campo dell'evento di esempio per aggiungerlo al trasformatore.

  4. In Output, verifica che l'output sia come desiderato.

Ora che i dati sono stati filtrati e migliorati, devi definire una destinazione a cui inviare i dati dell'evento.

Configurazione di una destinazione

Per configurare una destinazione

  1. Scegli Destinazione.

  2. In Dettagli, per Servizio di destinazione, scegli la destinazione. I campi visualizzati variano a seconda della destinazione scelta. Immetti informazioni specifiche per questo tipo di destinazione, come necessario.

Puoi anche trasformare i dati prima di inviarli alla destinazione.

(Facoltativo) Per definire il trasformatore di input

  1. Scegli Trasformatore di input di destinazione (facoltativo).

  2. Per Sample events/Event Payload, scegliete il tipo di evento di esempio.

  3. In Trasformatore, immetti la sintassi del trasformatore, ad esempio "Event happened at <$.detail.field>." dove <$.detail.field> è un riferimento a un campo dell'evento di esempio. Puoi anche fare doppio clic su un campo dell'evento di esempio per aggiungerlo al trasformatore.

  4. In Output, verifica che l'output sia come desiderato.

Ora che la pipe è configurata, assicurati che le relative impostazioni siano configurate correttamente.

Configurazione delle impostazioni della pipe

Una pipe è attiva per impostazione predefinita, ma è possibile disattivarla. È inoltre possibile specificare le autorizzazioni per le pipe, impostare la registrazione di log delle pipe e aggiungere tag.

Per configurare le impostazioni della pipe

  1. Scegli la scheda Impostazioni delle pipe.

  2. Per impostazione predefinita, le pipe appena create sono attive non appena vengono create. Se desideri creare una pipe inattiva, in Attivazione, per Attiva pipe, disattiva Attivo.

  3. In Autorizzazioni, per Ruolo di esecuzione, effettua una delle seguenti operazioni:

    1. Per EventBridge creare un nuovo ruolo di esecuzione per questa pipe, scegli Crea un nuovo ruolo per questa risorsa specifica. In Nome ruolo, puoi eventualmente modificare il nome del ruolo.

    2. Per utilizzare il ruolo di esecuzione, scegli Utilizza un ruolo esistente. In Nome ruolo, scegli il ruolo.

    Gestore dei ruoli abilitato

    Se il gestore dei ruoli è abilitato nel tuo account, EventBridge assegna il ruolo per te. EventBridge sostituisce le opzioni Crea un nuovo ruolo per questa risorsa specifica e Usa ruolo esistente con un'opzione Personalizza. Per utilizzare un ruolo diverso, scegli Personalizza. Per ulteriori informazioni, consulta Creazione di ruoli IAM nella Guida per l’utente IAM.

  4. (Facoltativo) Se hai specificato uno DynamoDB stream Kinesis or come sorgente pipe, puoi configurare una politica di ripetizione e una coda di lettere morte (DLQ).

    Per i criteri e la Dead-letter coda dei tentativi, facoltativi, procedi come segue:

    In Policy di ripetizione, procedi come segue:

    1. Se desideri attivare le policy di ripetizione, attiva Riprova. Per impostazione predefinita, nelle pipe appena create non è attivata la policy di ripetizione.

    2. Per Maximum age of event (Età massima dell'evento), immetti un valore compreso tra un minuto (00:01) e 24 ore (24:00).

    3. Per Tentativi, specifica un numero compreso tra 0 e 185.

    4. Se desideri utilizzare una coda per lettere morte (DLQ), attiva la coda, scegli il metodo che preferisci e scegli la Dead-letter coda o l'argomento che desideri utilizzare. Per impostazione predefinita, le pipe appena create non utilizzano una coda DLQ.

  5. Scegli il formato da utilizzare per crittografare i dati delle pipe. KMS key EventBridge

    Per ulteriori informazioni sulle modalità di EventBridge utilizzo KMS keys, vedereCrittografia dei dati a riposo.

    • Scegli Usa Chiave di proprietà di AWS per EventBridge per crittografare i dati utilizzando un Chiave di proprietà di AWS.

      Si Chiave di proprietà di AWS tratta di un account KMS key che EventBridge possiede e gestisce per essere utilizzato in più AWS account. In generale, a meno che non sia necessario verificare o controllare la chiave di crittografia che protegge le risorse, AN Chiave di proprietà di AWS è una buona scelta.

      Questa è l’impostazione predefinita.

    • Scegli Usa chiave gestita dal cliente per EventBridge per crittografare i dati utilizzando chiave gestita dal cliente quelli specificati o creati.

      Chiavi gestite dal cliente sono presenti KMS keys nell' AWS account che crei, possiedi e gestisci. Hai il pieno controllo su questi KMS keys.

      1. Specificane uno esistente chiave gestita dal cliente o scegli Crea un nuovo KMS key.

        EventBridge visualizza lo stato della chiave e tutti gli alias di chiave associati a quella specificata chiave gestita dal cliente.

  6. (Facoltativo) In Log (facoltativo), è possibile impostare il modo in cui EventBridge Pipes invia le informazioni sulla registrazione di log ai servizi supportati, incluso il modo in cui configurare tali log.

    Per ulteriori informazioni sulla registrazione di log di record di pipe, consulta Registrazione delle prestazioni di Amazon EventBridge Pipes.

    CloudWatch logs è selezionato come destinazione del registro per impostazione predefinita, così come il livello di ERROR registro. Quindi, per impostazione predefinita, EventBridge Pipes crea un nuovo gruppo di CloudWatch log a cui invia i record di log contenenti il ERROR livello di dettaglio.

    Per fare in modo che EventBridge Pipes invii i record di log a una qualsiasi delle destinazioni di log supportate, effettuate le seguenti operazioni:

    1. In Log (facoltativo), scegli le destinazioni a cui inviare i record di log.

    2. Per il livello di registro, scegliete il livello di informazioni EventBridge da includere nei record di registro. Il livello di log ERROR è selezionato per impostazione predefinita.

      Per ulteriori informazioni, consulta Specificazione del livello di log di EventBridge Pipes.

    3. Seleziona Includi dati di esecuzione se desideri includere EventBridge le informazioni sul payload degli eventi e le informazioni sulle richieste e risposte di servizio nei record di registro.

      Per ulteriori informazioni, consulta Inclusione dei dati di esecuzione nei log di EventBridge Pipes.

    4. Configura ogni destinazione di log selezionata:

      Per CloudWatch Logs i log, nella sezione CloudWatch log procedi come segue:

      • Per il gruppo di CloudWatch log, scegli se EventBridge creare un nuovo gruppo di log oppure puoi selezionare un gruppo di log esistente o specificare l'ARN di un gruppo di log esistente.

      • Per i nuovi gruppi di log, modifica il nome del gruppo di log come desiderato.

      CloudWatch logs è selezionato per impostazione predefinita.

      Per i log degli Firehose stream, in Firehose stream log, seleziona lo Firehose stream.

      Per Amazon S3 i log, in S3 logs procedi come segue:

      • Immetti il nome del bucket da utilizzare come destinazione dei log.

      • Inserisci l'ID AWS dell'account del proprietario del bucket.

      • Immetti il testo del prefisso da utilizzare quando EventBridge crea oggetti S3.

        Per ulteriori informazioni, consulta Organizzazione degli oggetti utilizzando i prefissi nella Guida per l'utente di Amazon Simple Storage Service .

      • Scegli come formattare EventBridge i record di registro S3:

  7. (Facoltativo) In Tag (facoltativo), scegli Aggiungi nuovo tag e immetti uno o più tag per la regola. Per ulteriori informazioni, consulta Etichettare le risorse in Amazon EventBridge.

  8. Scegli Crea pipe.

Convalida dei parametri di configurazione

Dopo aver creato una pipe, EventBridge convalida i seguenti parametri di configurazione:

  • Ruolo IAM: poiché l'origine di una pipe non può essere modificata dopo la creazione della pipe, EventBridge verifica che il ruolo IAM fornito possa accedere alla fonte.

    Nota

    EventBridge non esegue la stessa convalida per gli arricchimenti o i target perché possono essere aggiornati dopo la creazione della pipe.

  • Batching: EventBridge verifica che la dimensione del batch dell'origine non superi la dimensione massima del batch della destinazione. In caso affermativo, EventBridge richiede una dimensione del batch inferiore. Inoltre, se una destinazione non supporta il batching, non è possibile configurare il batching EventBridge per l'origine.

  • Arricchimenti: EventBridge verifica che la dimensione del batch per gli arricchimenti di API Gateway e API destination sia 1 perché sono supportate solo dimensioni di batch pari a 1.