Ziele von Amazon EventBridge Pipes - Amazon EventBridge
ZielparameterBerechtigungenAufrufen von ZielenAWS Batch JobwarteschlangenCloudWatch Gruppe „Logs“ECSAmazon-AufgabeWorkflows für Lambda-Funktionen und Step FunctionsTimestream für Tabelle LiveAnalytics

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Ziele von Amazon EventBridge Pipes

Sie können Daten in Ihrer Pipe an ein bestimmtes Ziel senden. Sie können die folgenden Ziele konfigurieren, wenn Sie eine Pipe in einrichten EventBridge:

Zielparameter

Einige Zieldienste senden die Nutzdaten des Ereignisses nicht an das Ziel, sondern behandeln das Ereignis als Auslöser für den Aufruf eines bestimmten Ereignisses. API EventBridge verwendet die PipeTargetParameters, um anzugeben, welche Informationen an dieses gesendet werden. API Diese umfassen u. a. folgende:

  • APIZiele (Die an ein API Ziel gesendeten Daten müssen der Struktur von entsprechenAPI. Sie müssen das InputTemplateObjekt verwenden, um sicherzustellen, dass die Daten korrekt strukturiert sind. Wenn Sie die ursprüngliche Ereignisnutzlast einbeziehen möchten, verweisen Sie darauf in der InputTemplate.)

  • APIGateway (Die an API Gateway gesendeten Daten müssen der Struktur von entsprechen. API Sie müssen das InputTemplateObjekt verwenden, um sicherzustellen, dass die Daten korrekt strukturiert sind. Wenn Sie die ursprüngliche Ereignisnutzlast einbeziehen möchten, verweisen Sie darauf in der InputTemplate.)

  • PipeTargetRedshiftDataParameters(Amazon Redshift API Redshift-Datencluster)

  • PipeTargetSageMakerPipelineParameters(Pipelines zur Erstellung von SageMaker Amazon-Runtime-Modellen)

  • PipeTargetBatchJobParameters (AWS Batch)

Anmerkung

EventBridge unterstützt nicht die gesamte JSON Path-Syntax und wertet sie nicht zur Laufzeit aus. Die unterstützte Syntax umfasst:

  • Punktnotation (zum Beispiel $.detail)

  • Bindestriche

  • Unterstriche

  • Alphanumerische Zeichen

  • Array-Indizes

  • Platzhalter (*)

Dynamische Pfadparameter

EventBridge Pipes-Zielparameter unterstützen die optionale dynamische JSON Pfadsyntax. Sie können diese Syntax verwenden, um JSON Pfade anstelle von statischen Werten anzugeben (z. B.$.detail.state). Der gesamte Wert muss ein JSON Pfad sein, nicht nur ein Teil davon. Zum Beispiel kann RedshiftParameters.Sql $.detail.state sein, aber es kann nicht "SELECT * FROM $.detail.state" sein. Diese Pfade werden zur Laufzeit dynamisch durch Daten aus der Ereignisnutzlast selbst am angegebenen Pfad ersetzt. Dynamische Pfadparameter können nicht auf neue oder transformierte Werte verweisen, die sich aus der Eingabetransformation ergeben. Die unterstützte Syntax für dynamische JSON Parameterpfade ist dieselbe wie bei der Transformation von Eingaben. Weitere Informationen finden Sie unter Amazon EventBridge Pipes-Eingabetransformation.

Die dynamische Syntax kann für alle Zeichenketten- und Nicht-Enum-Felder aller EventBridge Pipes-Anreicherungs- und Zielparameter verwendet werden, außer für:

Um beispielsweise das Ziel PartitionKey eines Pipe-Kinesis-Ziels auf einen benutzerdefinierten Schlüssel aus Ihrem Quell-Event festzulegen, legen Sie den KinesisTargetParameter fest. PartitionKeyauf:

  • "$.data.someKey" für eine Kinesis-Quelle

  • "$.body.someKey"für eine SQS Amazon-Quelle

Wenn es sich bei der Nutzlast des Ereignisses um eine gültige JSON Zeichenfolge handelt{"someKey":"someValue"}, wird beispielsweise der Wert aus dem JSON Pfad EventBridge extrahiert und als Zielparameter verwendet. In diesem Beispiel EventBridge würde die Kinesis PartitionKey auf“ gesetztsomeValue".

Berechtigungen

EventBridge Pipes benötigt die entsprechenden Berechtigungen, um die Ressourcen, die Ihnen gehören, API aufrufen zu können. EventBridge PIpesverwendet die IAM Rolle, die Sie für die Pipe angeben, für Anreicherungs- und Zielanrufe mithilfe des IAM Principalspipes.amazonaws.com.

Aufrufen von Zielen

EventBridge hat die folgenden Möglichkeiten, ein Ziel aufzurufen:

  • Synchron (Aufruftyp auf gesetztREQUEST_RESPONSE) — EventBridge wartet auf eine Antwort vom Ziel, bevor der Vorgang fortgesetzt wird.

  • Asynchron (Aufruftyp auf gesetztFIRE_AND_FORGET) — wartet EventBridge nicht auf eine Antwort, bevor der Vorgang fortgesetzt wird.

EventBridge Ruft Ziele bei Pipes mit geordneten Quellen standardmäßig synchron auf, da eine Antwort vom Ziel erforderlich ist, bevor mit dem nächsten Ereignis fortgefahren werden kann.

Wenn eine Quelle keine Reihenfolge erzwingt, wie z. B. eine standardmäßige SQS Amazon-Warteschlange, EventBridge kann ein unterstütztes Ziel synchron oder asynchron aufgerufen werden.

Mit Lambda-Funktionen und Step-Functions-Zustandsmaschinen können Sie den Aufruftyp konfigurieren.

Anmerkung

Für Step-Functions-Zustandsmaschinen müssen Standard-Workflows asynchron aufgerufen werden.

AWS Batch Job-Warteschlangen zielen auf Besonderheiten ab

Alle AWS Batch submitJob Parameter werden explizit mit konfiguriertBatchParameters, und wie alle Pipe-Parameter können sie dynamisch sein, indem sie einen JSON Pfad zu Ihrer Nutzlast für eingehende Ereignisse verwenden.

CloudWatch Protokolliert die Einzelheiten der Gruppenziele

Unabhängig davon, ob Sie einen Eingabe-Transformator nutzen oder nicht, wird die Ereignisnutzlast als Protokollnachricht verwendet. Sie können den Timestamp (oder den expliziten LogStreamName des Ziels) über CloudWatchLogsParameters in PipeTarget festlegen. Wie bei allen Pipe-Parametern können diese Parameter dynamisch sein, wenn Sie einen JSON Pfad zu Ihrer Payload für eingehende Ereignisse verwenden.

Besonderheiten des ECS Amazon-Aufgabenziels

Alle ECS runTask Amazon-Parameter werden explizit über konfiguriertEcsParameters. Wie bei allen Pipe-Parametern können diese Parameter dynamisch sein, wenn Sie einen JSON Pfad zu Ihrer Payload für eingehende Ereignisse verwenden.

Workflow-Zielspezifikationen für Lambda-Funktionen und Step Functions

Lambda- und Step-Funktionen haben keinen API Batch. Um Batches von Ereignissen aus einer Pipe-Quelle zu verarbeiten, wird der Batch in ein JSON Array konvertiert und als Eingabe an das Lambda- oder Step Functions Functions-Ziel übergeben. Weitere Informationen finden Sie unter Batching und Parallelität von Amazon EventBridge Pipes.

Timestream für Einzelheiten zu LiveAnalytics Tabellenzielen

Bei der Angabe einer Timestream LiveAnalytics for-Tabelle als Pipe-Ziel sollten unter anderem folgende Punkte berücksichtigt werden:

  • Apache Kafka-Streams (auch von Anbietern Amazon MSK oder Drittanbietern) werden derzeit nicht als Pipe-Quelle unterstützt.

  • Wenn Sie einen DynamoDB Stream Kinesis oder als Pipe-Quelle angegeben haben, müssen Sie die Anzahl der Wiederholungsversuche angeben.

    Weitere Informationen finden Sie unter Konfigurieren der Pipe-Einstellungen.