Aggiungi EventBridge eventi con Step Functions

Step Functions fornisce un'integrazione di servizi API per l'integrazione con Amazon EventBridge. Scopri come creare applicazioni basate sugli eventi inviando eventi personalizzati direttamente dai flussi di lavoro di Step Functions.

Per saperne di più sull'integrazione con AWS servizi in Step Functions, vedere Integrazione dei servizi e. Passaggio di parametri a un servizio API in Step Functions

Caratteristiche principali dell'integrazione ottimizzata EventBridge

• L'esecuzione ARN e la macchina a stati ARN vengono automaticamente aggiunte al Resources campo di ciascunaPutEventsRequestEntry.

• Se la risposta di PutEvents contiene un valore diverso da zeroFailedEntryCount, lo Task stato fallisce con l'errore. EventBridge.FailedEntry

Per utilizzare il PutEventsAPI, dovrai creare una EventBridge regola nel tuo account che corrisponda allo schema specifico degli eventi che invierai. È ad esempio possibile:

• Crea una funzione Lambda nel tuo account che riceva e stampa un evento che corrisponde a una EventBridge regola.

• Crea una EventBridge regola nel tuo account sul bus eventi predefinito che corrisponda a uno schema di eventi specifico e abbia come destinazione la funzione Lambda.

Per ulteriori informazioni, consultare:

• Aggiungere EventBridge eventi Amazon PutEvents nella Guida per l' EventBridge utente.

• Attendi una richiamata con Task Tokenin Modelli di integrazione dei servizi.

Quanto segue include un messaggio Task che invia un evento personalizzato:

{
  "Type": "Task",
  "Resource": "arn:aws:states:::events:putEvents",
  "Parameters": {
    "Entries": [
      {
        "Detail": {
          "Message": "MyMessage"
        },
        "DetailType": "MyDetailType",
        "EventBusName": "MyEventBus",
        "Source": "my.source"
      }
    ]
  },
  "End": true
}

Nota

Esiste una quota per la dimensione massima dei dati di input o risultato per un'attività in Step Functions. Ciò limita a 256 KB di dati come stringa con codifica UTF -8 quando si inviano o si ricevono dati da un altro servizio. Per informazioni, consulta Quote relative alle esecuzioni di macchine a stati.

Supportato EventBridge API

La sintassi supportata EventBridge API include:

• PutEvents

  • Sintassi della richiesta

  • Parametro supportato:

    • Entries

  • Sintassi della risposta

Gestione degli errori

PutEventsAPIaccetta una matrice di voci come input, quindi restituisce una matrice di voci di risultato. Finché l'PutEventsazione ha avuto successo, PutEvents restituirà una risposta di HTTP 200, anche se una o più immissioni hanno avuto esito negativo. PutEventsrestituisce il numero di immissioni non riuscite nel FailedEntryCount campo.

Step Functions verifica se FailedEntryCount è maggiore di zero. Se è maggiore di zero, Step Functions non riporta lo stato con l'erroreEventBridge.FailedEntry. Ciò consente di utilizzare la gestione degli errori integrata di Step Functions sugli stati delle attività per rilevare o riprovare in caso di immissioni non riuscite, anziché dover utilizzare uno stato aggiuntivo per analizzare i risultati FailedEntryCount della risposta.

Nota

Se hai implementato l'idempotenza e puoi riprovare in sicurezza su tutte le voci, puoi utilizzare la logica di riprova di Step Functions. Step Functions non rimuove le voci riuscite dall'array PutEvents di input prima di riprovare. Riprova invece con l'array di voci originale.

IAMpolitiche per le chiamate EventBridge

I seguenti modelli di esempio mostrano come AWS Step Functions genera IAM politiche basate sulle risorse nella definizione della macchina a stati. Per ulteriori informazioni, consulta In che modo Step Functions genera IAM politiche per servizi integrati e Scopri i modelli di integrazione dei servizi in Step Functions.

PutEvents

Risorse statiche

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "events:PutEvents"
            ],
            "Resource": [
                "arn:aws:events:us-east-1:123456789012:event-bus/stepfunctions-sampleproject-eventbus"
            ],
            "Effect": "Allow"
        }
    ]
}

Risorse dinamiche

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "events:PutEvents"
            ],
            "Resource": "arn:aws:events:*:*:event-bus/*"
        }
    ]
}