Rufen Sie EventBridge mit Step Functions auf

Step Functions kann bestimmte AWS Dienste direkt von Amazon States Language (ASL) aus steuern. Weitere Informationen hierzu finden Sie unter Arbeiten mit anderen -Services und Parameter an eine Service-API übergeben.

Wie unterscheidet sich die optimierte EventBridge Integration von der EventBridge AWS SDK-Integration

• Der Ausführungs-ARN und der State-Machine-ARN werden jeweils PutEventsRequestEntry automatisch an das jeweilige Resources Feld angehängt.

• Wenn die Antwort von einen Wert ungleich Null PutEvents FailedEntryCount enthält, schlägt der Task Status mit dem Fehler fehl. EventBridge.FailedEntry

Hinweise zur Konfiguration von IAM Berechtigungen bei der Verwendung Step Functions mit anderen AWS Diensten finden Sie unterIAM-Richtlinien für integrierte Dienste.

Step Functions bietet eine Service-Integrations-API für die Integration mit Amazon EventBridge. Auf diese Weise können Sie ereignisgesteuerte Anwendungen erstellen, indem Sie benutzerdefinierte Ereignisse direkt aus den Workflows von Step Functions senden.

Um die PutEvents API verwenden zu können, müssen Sie in Ihrem Konto eine EventBridge Regel erstellen, die dem spezifischen Muster der Ereignisse entspricht, die Sie senden werden. So können Sie beispielsweise:

• Erstellen Sie in Ihrem Konto eine Lambda-Funktion, die ein Ereignis empfängt und ausgibt, das einer EventBridge Regel entspricht.

• Erstellen Sie in Ihrem Konto auf dem Standard-Event-Bus eine EventBridge Regel, die einem bestimmten Ereignismuster entspricht und auf die Lambda-Funktion abzielt.

Weitere Informationen finden Sie hier:

• Hinzufügen von EventBridge Amazon-Veranstaltungen mit PutEvents im EventBridge Benutzerhandbuch.

• Warten auf einen Callback mit dem Aufgabentokenin Muster der Serviceintegration.

Anmerkung

In Step Functions gibt es ein Kontingent für die maximale Eingabe- oder Ergebnisdatengröße für eine Aufgabe. Dadurch sind Sie auf 256 KB an Daten als UTF-8-kodierte Zeichenfolge beschränkt, wenn Sie Daten an einen anderen Dienst senden oder von einem anderen Dienst empfangen. Siehe Kontingente im Zusammenhang mit der Ausführung von Zustandsmaschinen.

Unterstützte API EventBridge

Zu den unterstützten EventBridge APIs und Syntax gehören:

• PutEvents

  • Erforderliche Syntax

  • Unterstützte Parameter:

    • Entries

  • Antwortsyntax

Folgendes beinhaltet einenTask, der ein benutzerdefiniertes Ereignis sendet:

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

Fehlerbehandlung

Die PutEvents API akzeptiert ein Array von Einträgen als Eingabe und gibt dann ein Array von Ergebniseinträgen zurück. Solange die PutEvents Aktion erfolgreich war, PutEvents wird eine HTTP 200-Antwort zurückgegeben, auch wenn ein oder mehrere Einträge fehlgeschlagen sind. PutEventsgibt die Anzahl der fehlgeschlagenen Einträge im FailedEntryCount Feld zurück.

Step Functions prüft, ob der größer als Null FailedEntryCount ist. Wenn es größer als Null ist, schlägt Step Functions den Status mit dem Fehler fehlEventBridge.FailedEntry. Auf diese Weise können Sie die integrierte Fehlerbehandlung von Step Functions für Aufgabenstatus verwenden, um fehlgeschlagene Eingaben abzufangen oder erneut zu versuchen, anstatt einen zusätzlichen Status verwenden zu müssen, um die Antwort FailedEntryCount anhand der Antwort zu analysieren.

Anmerkung

Wenn Sie Idempotenz implementiert haben und sicher alle Einträge erneut versuchen können, können Sie die Wiederholungslogik von Step Functions verwenden. Step Functions entfernt erfolgreiche Einträge nicht aus dem PutEvents Eingabearray, bevor es erneut versucht wird. Stattdessen versucht es erneut mit dem ursprünglichen Array von Einträgen.