Diese Seite wurde von der Cloud Translation API übersetzt.

Workflows mit Eventarc auslösen

1. Übersicht

In diesem Lab erstellen Sie einen Eventarc-Trigger, der ein Pub/Sub-Thema mit dem Workflow-Dienst verbindet. Mit Eventarc können Sie die Dienst-zu-Dienst-Kommunikation entkoppeln, sodass Ihre Lösung erweiterbar und ereignisgesteuert ist. Sie erstellen einen Workflow, der mehrere Schritte umfasst, um einen Geschäftsprozess auszuführen und Kundenprämienpunkte für eine Bestellung bei Cymbal Eats zu berechnen. Der Workflow ruft eine private Cloud Run-Dienst-API auf, um die Geschäftslogik auszuführen. Der Cloud Run-Dienst ist so konfiguriert, dass nur interner Traffic zugelassen wird. Er erfordert eine Authentifizierung. Der Workflow veröffentlicht eine Nachricht im Pub/Sub-Thema, um den Order Service über berechnete Prämienpunkte zu informieren.

Was ist Eventarc?

Mit Eventarc können Sie ereignisgesteuerte Architekturen erstellen, ohne die zugrunde liegende Infrastruktur implementieren, anpassen oder verwalten zu müssen. Eventarc bietet eine standardisierte Lösung zum Verwalten des Flusses von Statusänderungen, sogenannten Ereignissen, zwischen entkoppelten Mikrodiensten. Bei Auslösung leitet Eventarc diese Ereignisse über Pub/Sub-Abos an verschiedene Ziele weiter (z. B. Workflows oder Cloud Run), während Sie die Bereitstellung, Sicherheit, Autorisierung, Beobachtbarkeit und Fehlerbehandlung für Sie verwalten.

Eventanbieter von Google

Mehr als 90 Google Cloud-Anbieter Diese Anbieter senden Ereignisse entweder direkt aus der Quelle (z. B. Cloud Storage) oder über Cloud-Audit-Logeinträge.
Pub/Sub-Anbieter. Diese Anbieter senden Ereignisse mithilfe von Pub/Sub-Nachrichten an Eventarc.

Drittanbieter

Drittanbieter sind Rechtssubjekte, die nicht zu Google gehören und eine Eventarc-Quelle anbieten.

Eventarc-Trigger

Cloud Pub/Sub-Ereignisse: Eventarc kann durch Nachrichten ausgelöst werden, die in Pub/Sub-Themen veröffentlicht werden.
Ereignisse in Cloud-Audit-Logs (CAL): Cloud-Audit-Logs bieten Audit-Logs zur Administratoraktivität und zum Datenzugriff für jedes Cloud-Projekt, jeden Ordner und jede Organisation.
Direkte Ereignisse: Eventarc kann durch verschiedene direkte Ereignisse ausgelöst werden, z. B. die Aktualisierung eines Cloud Storage-Buckets oder einer Firebase Remote Config-Vorlage.

Ziele von Veranstaltungen

Workflows
Cloud Run
GKE
Cloud Functions( 2nd gen)

Was sind Workflows?

Workflows ist ein vollständig verwalteter Dienst, mit dem Sie Mikrodienste, Aufgaben und APIs einbinden können. Workflows ist ein serverloser Dienst und lässt sich nach Bedarf skalieren.

Anwendungsfälle für Workflows:

Ereignisgesteuerte Workflows werden für definierte Trigger ausgeführt. Das ist beispielsweise der Fall, wenn eine neue Bestellung aufgegeben wird und Sie Treuepunkte für Ihre Kundschaft berechnen möchten. Wenn eine Bestellung storniert wird, kann die Veranstaltung veröffentlicht werden und alle interessierten Dienste verarbeiten das Ereignis.
Mit Workflows für Batchjobs werden Jobs regelmäßig mit Cloud Scheduler ausgeführt. Beispiel: Ein nächtlicher Job, bei dem Menüpunkte mit dem Status „Fehlgeschlagen“ geprüft und gelöscht werden sollen.

Workflows sind ideal für Workflows, die Dienste orchestrieren. Sie können Prozesse automatisieren, die Wartezeiten und Wiederholungsversuche von bis zu einem Jahr beinhalten.

Vorteile von Workflows:

Konfiguration statt Code:Reduzieren Sie technische Schulden, indem Sie die Logik in die Konfiguration verschieben, anstatt Code zu schreiben.
Vereinfachte Architektur: Mit zustandsorientierten Workflows können Sie komplexe Dienstintegrationen ohne zusätzliche Abhängigkeiten visualisieren und überwachen.
Verlässlichkeit und Fehlertoleranz einbeziehen Steuern Sie Fehler mit Standard- oder benutzerdefinierter Wiederholungslogik und Fehlerbehandlung selbst dann, wenn andere Systeme ausfallen. Prüfen Sie jeden Schritt auf Cloud Spanner, damit Sie den Fortschritt im Blick behalten können.
Keine Wartung erforderlich. Nach Bedarf skalieren: Es gibt keine Patches oder Wartungen. Sie zahlen nur, wenn Ihre Workflows ausgeführt werden. Während des Wartens oder der Inaktivität fallen keine Kosten an.

In diesem Lab konfigurieren Sie einen ereignisgesteuerten Workflow.

Lerninhalte

In diesem Lab lernen Sie Folgendes:

Pub/Sub-Thema und Eventarc zum Auslösen von Workflows konfigurieren
Workflow für den Aufruf des Cloud Run-Dienstes und das Veröffentlichen von Nachrichten in Pub/Sub konfigurieren
Anleitung zum Abfragen von strukturierten Workflows-Logs in Cloud Logging und über die gcloud CLI

Vorbereitung

In diesem Lab wird davon ausgegangen, dass Sie mit der Cloud Console und Cloud Shell-Umgebungen vertraut sind.
Vorkenntnisse zu Cloud Run und Cloud Pub/Sub sind hilfreich, aber nicht erforderlich.

2. Einrichtung und Anforderungen

Cloud-Projekt einrichten

Melden Sie sich in der Google Cloud Console an und erstellen Sie ein neues Projekt oder verwenden Sie ein vorhandenes Projekt. Wenn Sie noch kein Gmail- oder Google Workspace-Konto haben, müssen Sie eines erstellen.

Der Projektname ist der Anzeigename für die Projektteilnehmer. Es handelt sich um eine Zeichenfolge, die von Google APIs nicht verwendet wird. Sie können sie jederzeit aktualisieren.
Die Projekt-ID ist für alle Google Cloud-Projekte eindeutig und unveränderlich. Sie kann nach dem Festlegen nicht mehr geändert werden. Die Cloud Console generiert automatisch einen eindeutigen String. ist Ihnen meist egal, was es ist. In den meisten Codelabs musst du dich auf die Projekt-ID beziehen, die üblicherweise als PROJECT_ID gekennzeichnet ist. Wenn Ihnen die generierte ID nicht gefällt, können Sie eine weitere zufällige ID erstellen. Alternativ können Sie einen eigenen verwenden und nachsehen, ob er verfügbar ist. Sie kann nach diesem Schritt nicht mehr geändert werden und bleibt für die Dauer des Projekts bestehen.
Zur Information gibt es noch einen dritten Wert, die Projektnummer, die von manchen APIs verwendet wird. Weitere Informationen zu allen drei Werten finden Sie in der Dokumentation.

Als Nächstes müssen Sie in der Cloud Console die Abrechnung aktivieren, um Cloud-Ressourcen/APIs verwenden zu können. Dieses Codelab sollte ohne großen Aufwand betrieben werden. Wenn Sie Ressourcen herunterfahren möchten, um über diese Anleitung hinaus keine Kosten zu verursachen, können Sie die von Ihnen erstellten Ressourcen oder das gesamte Projekt löschen. Neue Google Cloud-Nutzer haben Anspruch auf eine kostenlose Testversion von 300$.

Umgebung einrichten

Aktivieren Sie Cloud Shell, indem Sie auf das Symbol rechts neben der Suchleiste klicken.

Klonen Sie das Repository und gehen Sie zum Verzeichnis. Kopieren Sie dann den folgenden Befehl, fügen Sie ihn in das Terminal ein und drücken Sie die Eingabetaste:

git clone https://github.com/GoogleCloudPlatform/cymbal-eats.git && cd cymbal-eats/customer-service

Stellen Sie die erforderlichen Abhängigkeiten bereit, indem Sie den lab-setup.sh ausführen

Folgende Ressourcen werden erstellt:

AlloyDB-Cluster und -Instanz
Artifact Registry zum Speichern von Container-Images für Cloud Run Job und Customer Service
VPC-Zugriffs-Connector für den Cloud Run-Dienst und -Job, um mit der AlloyDB-Datenbank zu kommunizieren
Cloud Run-Job zum Erstellen einer AlloyDB-Datenbank
Cloud Run-Kundendienst: Java-basierter Mikrodienst, der das Quarkus-Framework verwendet.

./lab-setup.sh

Wenn Sie zur Autorisierung aufgefordert werden, klicken Sie auf „Autorisieren“. um fortzufahren.

Die Einrichtung dauert etwa 10 Minuten.

Warten Sie, bis das Skript abgeschlossen ist und die Ausgabe unten angezeigt wird, bevor Sie weitere Schritte ausführen.

Deploying container to Cloud Run service [customer-service] in project [cymbal-eats-19227-5681] region [us-east1]
OK Deploying new service... Done.                                                   
  OK Creating Revision...
  OK Routing traffic...
Done.
Service [customer-service] revision [customer-service-00001-mid] has been deployed and is serving 100 percent of traffic.
Service URL: https://customer-service-e4p5zon5rq-ue.a.run.app

Sie können sich mit dem nächsten Abschnitt vertraut machen und dann zum nächsten Schritt zurückkehren.

3. Workflow für Überprüfung

Kernkonzepte für Workflows

Ein Workflow besteht aus einer Reihe von Schritten, die unter Verwendung der Workflow-Syntax( YAML oder JSON) beschrieben werden.

Nachdem ein Workflow erstellt wurde, wird er bereitgestellt. Der Workflow kann nun ausgeführt werden.

Eine Ausführung ist eine einzelne Ausführung der Logik, die in der Definition eines Workflows enthalten ist. Für einen Workflow, der nicht ausgeführt wurde, fallen keine Kosten an. Alle Workflowausführungen sind unabhängig und die schnelle Skalierung des Produkts ermöglicht eine hohe Anzahl gleichzeitiger Ausführungen.

Ausführungskontrollen

Schritte: Um einen Workflow zu erstellen, definieren Sie die gewünschte steps und die Ausführungsreihenfolge mithilfe der Workflows-Syntax. Jeder Workflow muss mindestens einen Schritt enthalten.
Bedingungen: Sie können einen switch-Block als Auswahlmechanismus verwenden, der es dem Wert eines Ausdrucks ermöglicht, den Ablauf bei der Ausführung eines Workflows zu steuern.
Iterationen: Sie können eine for-Schleife verwenden, um über eine Zahlenfolge oder durch eine Sammlung von Daten, z. B. eine Liste oder Map, zu iterieren.
Untergeordnete Workflows: Ein untergeordneter Workflow funktioniert ähnlich wie eine Routine oder eine Funktion in einer Programmiersprache. Sie können also einen Schritt oder eine Reihe von Schritten kapseln, die der Workflow mehrmals wiederholt.

Ausführungen auslösen

Manuell: Sie können Workflows entweder über die Google Cloud Console oder mit der Google Cloud CLI über die Befehlszeile verwalten.
Programmatisch: Mit den Cloud-Clientbibliotheken für die Workflows API oder die REST API können Workflows verwaltet werden.
Geplant: Mit Cloud Scheduler können Sie einen Workflow nach einem bestimmten Zeitplan ausführen.

Laufzeitargumente

Sie können auf die zur Laufzeit übergebenen Daten zugreifen, indem Sie Ihrem Hauptworkflow (in einem Hauptblock) das Feld params hinzufügen. Der Hauptblock akzeptiert ein einzelnes Argument mit einem beliebigen gültigen JSON-Datentyp. Das Feld "params" gibt die Variable an, in der der Workflow die von Ihnen übergebenen Daten speichert.

Authentifizierung vom Workflow zur Cloud Run-Dienstauthentifizierung

Der Kundenservice ist eine in diesem Repository enthaltene Beispielanwendung, die in Cloud Run ausgeführt wird und so konfiguriert ist, dass nur authentifizierte Anfragen von internen Netzwerken zugelassen werden. Sie konfigurieren Workflows so, dass der Anfrage zur Authentifizierung beim Cloud Run-Dienst ein von Google signiertes OpenID Connect-Token(OIDC) hinzugefügt wird.

In der Dokumentation finden Sie weitere Informationen zur Dienst-zu-Dienst-Authentifizierung.

Die Workflowauthentifizierung wird im Block args mithilfe des Abschnitts auth konfiguriert.

rewardsWorkflow.yaml.tmpl

   - create_customer:
        call: http.post
        args:
          url: CUSTOMER_SERVICE_URL/customer
          auth:
            type: OIDC

Workflowlogik

Wenn kein Kunde vorhanden ist, wird in diesem Workflow zuerst ein API-Aufruf ausgeführt, um einen Kunden zu erstellen und dann die Prämienpunkte zu aktualisieren. Basierend auf dem Gesamtbetrag der Bestellung wählt der Workflow einen Multiplikator aus, um Prämienpunkte für den Kunden zu berechnen. Weitere Informationen finden Sie im Beispiel unten.

  - calculate_multiplier:
        switch:
          - condition: ${totalAmount < 10}
            steps:
              - set_multiplier1:
                  assign:
                    - multiplier: 2
          - condition: ${totalAmount >= 10 and totalAmount < 25}
            steps:
              - set_multiplier2:
                  assign:
                    - multiplier: 3
          - condition: ${totalAmount >= 25}
            steps:
              - set_multiplier3:
                  assign:
                    - multiplier: 5
    - calculate_rewards:
        assign:
            - rewardPoints: ${customerRecord.rewardPoints * multiplier}

4. Workflow konfigurieren und bereitstellen

Umgebungsvariablen einrichten:

export REGION=us-east1

export CUSTOMER_SERVICE_URL=$(gcloud run services describe customer-service \
  --platform managed \
  --region $REGION \
  --format=json | jq \
  --raw-output ".status.url")

echo $CUSTOMER_SERVICE_URL

Ersetzen Sie die Dienst-URL in der Workflowvorlage:

sed "s@CUSTOMER_SERVICE_URL@$CUSTOMER_SERVICE_URL@g" rewardsWorkflow.yaml.tmpl > rewardsWorkflow.yaml

Legen Sie den Speicherort für die Umgebungsvariablen des Workflows-Dienstes und -Projekts fest:

gcloud config set workflows/location ${REGION}

export PROJECT_ID=$(gcloud config get-value project)
export PROJECT_NUMBER=$(gcloud projects describe $PROJECT_ID --format='value(projectNumber)')
export PROJECT_NAME=$(gcloud projects describe $PROJECT_ID --format='value(name)')

Erstellen Sie ein benutzerdefiniertes Dienstkonto für den Workflow mit den folgenden Berechtigungen:

Cloud Run-Dienst aufrufen
Anrufprotokollierungs-APIs
Nachrichten in Pub/Sub-Thema veröffentlichen

export WORKFLOW_SERVICE_ACCOUNT=workflows-cloudrun-sa

gcloud iam service-accounts create ${WORKFLOW_SERVICE_ACCOUNT}

gcloud projects add-iam-policy-binding $PROJECT_ID \
  --member "serviceAccount:${WORKFLOW_SERVICE_ACCOUNT}@$PROJECT_ID.iam.gserviceaccount.com" \
  --role "roles/run.invoker"

gcloud projects add-iam-policy-binding $PROJECT_ID \
  --member "serviceAccount:${WORKFLOW_SERVICE_ACCOUNT}@$PROJECT_ID.iam.gserviceaccount.com" \
  --role "roles/logging.logWriter"

gcloud projects add-iam-policy-binding $PROJECT_ID \
  --member "serviceAccount:${WORKFLOW_SERVICE_ACCOUNT}@$PROJECT_ID.iam.gserviceaccount.com" \
  --role "roles/pubsub.publisher"

Bereitstellungsworkflow. Der Workflow ist so konfiguriert, dass das im vorherigen Schritt erstellte Dienstkonto verwendet wird:

export WORKFLOW_NAME=rewardsWorkflow

gcloud workflows deploy ${WORKFLOW_NAME} \
  --source=rewardsWorkflow.yaml \
  --service-account=${WORKFLOW_SERVICE_ACCOUNT}@$PROJECT_ID.iam.gserviceaccount.com

Sehen Sie sich die Quelle des Workflows und andere Details an(Tab „Trigger“). Derzeit sind keine Trigger zum Ausführen dieses Workflows konfiguriert. Die Einrichtung erfolgt im nächsten Schritt.

5. Pub/Sub-Themen und Eventarc-Trigger konfigurieren

Als Nächstes erstellen Sie zwei Pub/Sub-Themen und konfigurieren einen Eventarc-Trigger.

Der Bestelldienst veröffentlicht Nachrichten mit Informationen zu neuen Bestellungen in order-topic.

Der Workflow veröffentlicht Nachrichten mit Informationen zu Prämienpunkten und Gesamtbetrag für Bestellungen in order-points-topic. Order Service(nicht in diesem Lab bereitgestellt) enthält einen Endpunkt, der vom Push-Abo für order-points-topic, verwendet wird, um die Prämienpunkte und den Gesamtbetrag pro Bestellung zu aktualisieren.

Erstellen Sie neue Pub/Sub-Themen:

export TOPIC_ID=order-topic
export ORDER_POINTS_TOPIC_ID=order-points-topic
gcloud pubsub topics create $TOPIC_ID --project=$PROJECT_ID
gcloud pubsub topics create $ORDER_POINTS_TOPIC_ID --project=$PROJECT_ID

Legen Sie den Standort für den Eventarc-Dienst fest:

gcloud config set eventarc/location ${REGION}

Erstellen Sie ein benutzerdefiniertes Dienstkonto, das vom Eventarc-Trigger zum Ausführen von Workflows verwendet wird.

export TRIGGER_SERVICE_ACCOUNT=eventarc-workflow-sa

gcloud iam service-accounts create ${TRIGGER_SERVICE_ACCOUNT}

Gewähren Sie dem Dienstkonto Zugriff, um Workflows auszuführen.

gcloud projects add-iam-policy-binding ${PROJECT_ID} \
  --member="serviceAccount:${TRIGGER_SERVICE_ACCOUNT}@${PROJECT_ID}.iam.gserviceaccount.com" \
  --role="roles/workflows.invoker"

Erstellen Sie einen Eventarc-Trigger, um Pub/Sub-Nachrichten zu überwachen und an Workflows zu senden.

gcloud eventarc triggers create new-orders-trigger \
  --destination-workflow=${WORKFLOW_NAME} \
  --destination-workflow-location=${REGION} \
  --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
  --service-account="${TRIGGER_SERVICE_ACCOUNT}@${PROJECT_ID}.iam.gserviceaccount.com" \
  --transport-topic=$TOPIC_ID

Beispielausgabe:

Creating trigger [new-orders-trigger] in project [qwiklabs-gcp-01-1a990bfcadb3], location [us-east1]...done.     
Publish to Pub/Sub topic [projects/qwiklabs-gcp-01-1a990bfcadb3/topics/order-topic] to receive events in Workflow [rewardsWorkflow].
WARNING: It may take up to 2 minutes for the new trigger to become active.

Prüfen Sie den erstellten Eventarc-Trigger.

Prüfen Sie das erstellte Abo für den Trigger.

Überprüfen Sie die Änderungen auf der Workflowseite. Ein neuer Trigger wurde hinzugefügt.

6. Workflow testen

Um den Bestelldienst zu simulieren, senden Sie Nachrichten von Cloud Shell aus an das Pub/Sub-Thema und prüfen die Logs des Cloud Run-Kundenservice in der Cloud Console.

export TOPIC_ID=order-topic
gcloud pubsub topics publish $TOPIC_ID --message '{"userId":"id1","orderNumber":123456,"name":"Angela Jensen","email":"ajensen9090+eats@gmail.com","address":"1845 Denise St","city":"Mountain View","state":"CA","zip":"94043","orderItems":[{"id":7,"createDateTime":"2022-03-17T21:51:44.968584","itemImageURL":"https://images.unsplash.com/photo-1618449840665-9ed506d73a34?ixlib=rb-1.2.1&ixid=MnwxMjA3fDB8MHxwaG90by1wYWdlfHx8fGVufDB8fHx8&auto=format&fit=crop&w=687&q=80","itemName":"Curry Plate","itemPrice":12.5,"itemThumbnailURL":"https://images.unsplash.com/photo-1618449840665-9ed506d73a34?ixlib=rb-1.2.1&ixid=MnwxMjA3fDB8MHxwaG90by1wYWdlfHx8fGVufDB8fHx8&auto=format&fit=crop&w=687&q=80","spiceLevel":0,"status":"Ready","tagLine":"Spicy touch for your taste buds","updateDateTime":"2022-03-18T01:30:29.340584","inventory":8,"quantity":1}]}'

Beispielausgabe:

messageIds:
- '5063709859203105'

Sehen Sie sich Details und Logs zur Workflowausführung an.

7. Strukturiertes Logging für Workflows

Der Workflow ist so konfiguriert, dass strukturierte Logs im JSON-Format geschrieben werden. Die Logs werden mithilfe der Cloud Logging API, der Ressource workflows.googleapis.com/Workflow und unter dem Lognamen projects/${PROJECT_ID}/logs/Workflows geschrieben.

Überprüfen Sie die Logging-Konfiguration unten.

    - log_totalAmount:
        call: sys.log
        args:
            json:
              orderNumber: ${order.orderNumber}
              totalAmount: ${totalAmount}
              multiplier: ${multiplier}
              totalRewardPoints: ${rewardPoints}
              orderRewardPoints: ${orderRewardPoints}
            severity: INFO

Öffnen Sie den Log-Explorer in der Console und führen Sie eine Abfrage für verarbeitete Bestellungen aus, deren Gesamtbetrag über 2 $liegt.

Verwenden Sie die folgende Abfrage und ersetzen Sie die Projekt-ID(qwiklabs-gcp-01-1a990bfcadb3) durch Ihre aktuelle Projekt-ID:

resource.type="workflows.googleapis.com/Workflow" AND 
logName=projects/qwiklabs-gcp-01-1a990bfcadb3/logs/Workflows AND 
jsonPayload.totalAmount > 2 AND 
timestamp >= "2022-11-01T23:59:59Z" AND 
timestamp <= "2023-11-05T00:00:00Z"

Beispielausgabe:

Öffnen Sie Cloud Shell und verwenden Sie die gcloud CLI, um Logs zu lesen. Verwenden Sie dazu die folgenden Befehle.

Ersetzen Sie die Projekt-ID(qwiklabs-gcp-01-1a990bfcadb3) durch Ihre aktuelle Projekt-ID.

gcloud logging read 'resource.type="workflows.googleapis.com/Workflow" AND logName=projects/qwiklabs-gcp-01-1a990bfcadb3/logs/Workflows AND jsonPayload.totalAmount > 2 AND timestamp >= "2022-11-01T23:59:59Z" AND timestamp <= "2023-11-05T00:00:00Z"' --limit 10 --format="table(jsonPayload.orderNumber,jsonPayload.totalAmount,jsonPayload.orderRewardPoints,jsonPayload.totalRewardPoints,jsonPayload.multiplier)"

Beispielausgabe im table-Format:

Ersetzen Sie die Projekt-ID(qwiklabs-gcp-01-1a990bfcadb3) durch Ihre aktuelle Projekt-ID.

gcloud logging read 'resource.type="workflows.googleapis.com/Workflow" AND logName=projects/qwiklabs-gcp-01-1a990bfcadb3/logs/Workflows AND jsonPayload.totalAmount > 2 AND timestamp >= "2022-11-01T23:59:59Z" AND timestamp <= "2023-11-05T00:00:00Z"' --limit 10 --format=json | jq

Beispielausgabe im json-Format:

8. Kundendatensätze prüfen

(Optionale Schritte) Derzeit ist customer-service so konfiguriert, dass nur Traffic von internen Netzwerken akzeptiert wird.

Führen Sie die folgenden Befehle aus, um die Dienst-URL zu speichern und den Kundenservice aufzurufen.

export REGION=us-east1
CUSTOMER_SERVICE_URL=$(gcloud run services describe customer-service \
    --region=$REGION \
    --format=json | jq \
    --raw-output ".status.url")

curl -H "Authorization: Bearer $(gcloud auth print-identity-token)" $CUSTOMER_SERVICE_URL/customer

Sie erhalten eine Fehlermeldung, dass der Zugriff unzulässig ist.

<html><head>
<meta http-equiv="content-type" content="text/html;charset=utf-8">
<title>403 Forbidden</title>
</head>
<body text=#000000 bgcolor=#ffffff>
<h1>Error: Forbidden</h1>
<h2>Access is forbidden.</h2>
<h2></h2>
</body></html>

Ändern Sie die Cloud Run-Einstellungen für customer-service eingehenden Traffic in „Allow all traffic“, um vorhandene Kundeneinträge anzusehen und klicken Sie auf „Speichern“.

Dadurch wird der Endpunkt veröffentlicht und Sie können die Customer Service API mit curl über Cloud Shell aufrufen.

Führen Sie die folgenden Befehle aus, um die Service-URL zu speichern und Bestandskunden aufzulisten.

CUSTOMER_SERVICE_URL=$(gcloud run services describe customer-service \
    --region=$REGION \
    --format=json | jq \
    --raw-output ".status.url")

curl -H "Authorization: Bearer $(gcloud auth print-identity-token)" $CUSTOMER_SERVICE_URL/customer | jq

Beispielausgabe:

[
  {
    "id": "id1",
    "rewardPoints": 3,
    "address": "1845 Denise St",
    "city": "Mountain View",
    "createDateTime": "2022-11-11T15:56:45.487566",
    "email": "ajensen9090+eats@gmail.com",
    "name": "Angela Jensen",
    "state": "CA",
    "updateDateTime": "2022-11-11T15:56:45.866125",
    "zip": "94043"
  }
]

Führen Sie den Befehl aus, um eine neue Bestellung mehrmals zu veröffentlichen und Kundenprämienpunkte mit dem Befehl „curl“ zu prüfen.

Neue Auftragsnachricht veröffentlichen:

export TOPIC_ID=order-topic
gcloud pubsub topics publish $TOPIC_ID --message '{"userId":"id1","orderNumber":123456,"name":"Angela Jensen","email":"ajensen9090+eats@gmail.com","address":"1845 Denise St","city":"Mountain View","state":"CA","zip":"94043","orderItems":[{"id":7,"createDateTime":"2022-03-17T21:51:44.968584","itemImageURL":"https://images.unsplash.com/photo-1618449840665-9ed506d73a34?ixlib=rb-1.2.1&ixid=MnwxMjA3fDB8MHxwaG90by1wYWdlfHx8fGVufDB8fHx8&auto=format&fit=crop&w=687&q=80","itemName":"Curry Plate","itemPrice":12.5,"itemThumbnailURL":"https://images.unsplash.com/photo-1618449840665-9ed506d73a34?ixlib=rb-1.2.1&ixid=MnwxMjA3fDB8MHxwaG90by1wYWdlfHx8fGVufDB8fHx8&auto=format&fit=crop&w=687&q=80","spiceLevel":0,"status":"Ready","tagLine":"Spicy touch for your taste buds","updateDateTime":"2022-03-18T01:30:29.340584","inventory":8,"quantity":1}]}'

Prämienpunkte für Kunden überprüfen:

curl -H "Authorization: Bearer $(gcloud auth print-identity-token)" $CUSTOMER_SERVICE_URL/customer | jq

Prüfen Sie die Logs. Ersetzen Sie die Projekt-ID(qwiklabs-gcp-01-1a990bfcadb3) durch Ihre aktuelle Projekt-ID.

gcloud logging read 'resource.type="workflows.googleapis.com/Workflow" AND logName=projects/qwiklabs-gcp-01-1a990bfcadb3/logs/Workflows AND jsonPayload.totalAmount > 2 AND timestamp >= "2022-11-01T23:59:59Z" AND timestamp <= "2023-11-05T00:00:00Z"' --limit 10 --format="table(jsonPayload.orderNumber,jsonPayload.totalAmount,jsonPayload.orderRewardPoints,jsonPayload.totalRewardPoints,jsonPayload.multiplier)"

9. Glückwunsch!

Glückwunsch, du hast das Codelab abgeschlossen.

Behandelte Themen:

Workflows konfigurieren
Eventarc-Trigger für Workflows konfigurieren
Cloud Run-Dienst aus Workflows aufrufen
Anleitung zum Abfragen strukturierter Logs in Cloud Logging und über die gcloud CLI

Nächste Schritte:

Weitere Codelabs von Cymbal Eats:

Bereinigen

Damit Ihrem Google Cloud-Konto die in dieser Anleitung verwendeten Ressourcen nicht in Rechnung gestellt werden, können Sie entweder das Projekt löschen, das die Ressourcen enthält, oder das Projekt beibehalten und die einzelnen Ressourcen löschen.

Projekt löschen

Am einfachsten vermeiden Sie weitere Kosten durch Löschen des für die Anleitung erstellten Projekts.