Diese Seite wurde von der Cloud Translation API übersetzt.

Empfangene Ereignisse formatieren

Erweitert

Eine Pipeline verbindet einen Bus mit einem Ziel und leitet Ereignisnachrichten an dieses Ziel weiter. Sie können eine Pipeline so konfigurieren, dass Ereignisdaten in einem bestimmten Format erwartet werden. Bevor Ereignisse an ein Ziel gesendet werden, können Sie sie auch von einem unterstützten Format in ein anderes konvertieren. Möglicherweise müssen Sie Ereignisse beispielsweise an einen Endpunkt weiterleiten, der nur Avro-Daten akzeptiert.

Unterstützte Formate

Die folgenden Formatkonvertierungen werden unterstützt:

Avro zu JSON
Avro zu Protobuf
JSON zu Avro
JSON nach Protobuf
Protobuf zu Avro
Protobuf nach JSON

Wichtige Hinweise:

Wenn Sie das Format von Ereignissen konvertieren, wird nur die Ereignisnutzlast und nicht die gesamte Ereignisnachricht konvertiert.
Wenn für eine Pipeline ein Eingabedatenformat angegeben ist, müssen alle Ereignisse diesem Format entsprechen. Alle Ereignisse, die nicht dem erwarteten Format entsprechen, werden als dauerhafte Fehler behandelt.
Wenn für eine Pipeline kein Format für eingehende Daten angegeben ist, kann auch kein Format für ausgehende Daten festgelegt werden.
Bevor ein Ereignisformat für ein bestimmtes Ziel konvertiert wird, werden alle konfigurierten Datentransformationen angewendet.
Ereignisse werden immer im CloudEvents-Format mit einer HTTP-Anfrage im Binärinhaltsmodus gesendet, sofern Sie keine Nachrichtenbindung angeben.
JSON-Schemas werden dynamisch erkannt. Für Protobuf-Schemadefinitionen können Sie nur einen Typ der obersten Ebene definieren. Importanweisungen, die sich auf andere Typen beziehen, werden nicht unterstützt. Für Schemadefinitionen ohne syntax-Kennung wird standardmäßig proto2 verwendet. Beachten Sie, dass die Größe des Schemas begrenzt ist.

Pipeline zum Formatieren von Ereignissen konfigurieren

Sie können eine Pipeline in der Google Cloud Console oder mit der gcloud CLI so konfigurieren, dass Ereignisdaten in einem bestimmten Format erwartet oder Ereignisdaten von einem Format in ein anderes konvertiert werden.

Console

Rufen Sie in der Google Cloud Console die Seite Eventarc > Pipelines auf.

Zu Pipelines
Sie können eine Pipeline erstellen oder, wenn Sie eine Pipeline aktualisieren möchten, auf den Namen der Pipeline klicken.

Das Aktualisieren einer Pipeline kann länger als 10 Minuten dauern.
Klicken Sie auf der Seite Pipelinedetails auf Bearbeiten.
Führen Sie im Bereich Ereignisvermittlung die folgenden Schritte aus:
1. Klicken Sie das Kästchen Transformation anwenden an.
2. Wählen Sie in der Liste Eingehendes Format das entsprechende Format aus.
  
  Wenn für eine Pipeline ein Format für eingehende Daten angegeben ist, müssen alle Ereignisse diesem Format entsprechen. Alle Ereignisse, die nicht dem erwarteten Format entsprechen, werden als dauerhafte Fehler behandelt.
3. Für Avro- oder Protobuf-Formate müssen Sie ein Eingangsschema angeben. Optional können Sie auch ein eingehendes Schema hochladen, anstatt es direkt anzugeben.
4. Geben Sie im Feld CEL-Ausdruck einen Transformationsausdruck in CEL ein.
5. Klicken Sie auf Weiter.
Führen Sie im Bereich Ziel die folgenden Schritte aus:
1. Wählen Sie gegebenenfalls in der Liste Ausgabeformat ein Format aus.
  
  Wenn für eine Pipeline kein Format für eingehende Daten angegeben ist, kann kein Format für ausgehende Daten festgelegt werden.
2. Optional: Wenden Sie eine Nachrichtenbindung an. Weitere Informationen finden Sie unter Nachrichtenbindung.
Klicken Sie auf Speichern.

gcloud

Öffnen Sie ein Terminalfenster.
Sie können mit dem Befehl gcloud beta eventarc pipelines update eine Pipeline erstellen oder eine Pipeline aktualisieren:

Das Aktualisieren einer Pipeline kann länger als 10 Minuten dauern.
```
gcloud beta eventarc pipelines update PIPELINE_NAME \
    --location=REGION \
    --INPUT_PAYLOAD_FLAG \
    --destinations=OUTPUT_PAYLOAD_KEY
```
Ersetzen Sie Folgendes:
- PIPELINE_NAME: ID der Pipeline oder ein voll qualifizierter Name
- REGION: ein unterstützter Standort für Eventarc Advanced
  
  Alternativ können Sie das Attribut „Speicherort“ der gcloud CLI festlegen:
```
gcloud config set eventarc/location REGION
```
- INPUT_PAYLOAD_FLAG: ein Flag für das Eingabedatenformat, das einen der folgenden Werte haben kann:
  - --input-payload-format-avro-schema-definition
  - --input-payload-format-json
  - --input-payload-format-protobuf-schema-definition
  Wenn für eine Pipeline ein Eingabedatenformat angegeben ist, müssen alle Ereignisse diesem Format entsprechen. Alle Ereignisse, die nicht dem erwarteten Format entsprechen, werden als dauerhafte Fehler behandelt.
- OUTPUT_PAYLOAD_KEY: Ein Schlüssel für das Ausgabedatenformat, der einen der folgenden Werte haben kann:
  - output_payload_format_avro_schema_definition
  - output_payload_format_json
  - output_payload_format_protobuf_schema_definition
  Wenn Sie einen Schlüssel für das Ausgabedatenformat festlegen, müssen Sie auch ein Flag für das Eingabedatenformat angeben.
Beispiele:

Im folgenden Beispiel wird mit einem --input-payload-format-protobuf-schema-definition-Flag angegeben, dass die Pipeline Ereignisse in einem Protobuf-Datenformat mit einem bestimmten Schema erwartet:
```
gcloud beta eventarc pipelines update my-pipeline \
    --input-payload-format-protobuf-schema-definition \
'
  syntax = "proto3";
  message schema {
    string name = 1;
    string severity = 2;
  }
'
```
Im folgenden Beispiel wird ein output_payload_format_avro_schema_definition-Schlüssel und ein --input-payload-format-avro-schema-definition-Flag verwendet, um eine Pipeline zu erstellen, die Ereignisse im Avro-Format erwartet und im selben Format ausgibt:
```
gcloud beta eventarc pipelines create my-pipeline \
    --location=us-central1 \
    --destinations=http_endpoint_uri='https://example-endpoint.com',output_payload_format_avro_schema_definition='{"type": "record", "name": "my_record", "fields": [{"name": "my_field", "type": "string"}]}' \
    --input-payload-format-avro-schema-definition='{"type": "record", "name": "my_record", "fields": [{"name": "my_field", "type": "string"}]}'
```
Im folgenden Beispiel werden ein output_payload_format_protobuf_schema_definition-Schlüssel und ein --input-payload-format-avro-schema-definition-Flag verwendet, um eine Pipeline zu aktualisieren und ihre Ereignisdaten mithilfe von Schemadefinitionen von Avro in Protobuf umzuwandeln:
```
gcloud beta eventarc pipelines update my-pipeline \
    --location=us-central1 \
    --destinations=output_payload_format_protobuf_schema_definition='message MessageProto {string prop1 = 1; string prop2 = 2;}' \
    --input-payload-format-avro-schema-definition= \
    '
    {
      "type": "record",
      "name": "MessageProto",
      "fields": [
        { "name" : "prop1", "type": "string" },
        { "name" : "prop2", "type": "string" },
      ]
    }
    '
```