Laufzeitargumente in einer Ausführungsanfrage übergeben

Sie können Laufzeitargumente in einer Workflowausführungsanfrage übergeben und auf diese mithilfe von Workflow-Variablen.

Workflow einrichten, der Laufzeitargumente empfängt

So richten Sie einen Workflow ein, der Laufzeitargumente empfängt, die Sie im Rahmen einer Ausführungsanfrage an ihn übergeben:

  1. Folgen Sie der Anleitung, um erstellen neuen Workflow erstellen oder einen bestehenden Workflow auswählen, update, aber noch nicht bereitstellen.

  2. Fügen Sie der Definition des Hauptworkflows das Feld params hinzu. Stellen Sie sicher, dass der Argumentname wird in eckige Klammern gesetzt und der Hauptworkflow ist in einem main-Block:

    YAML

    main:
      params: [ARG_NAME]
      steps:
        ...

    JSON

    {
      "main": {
        "params": ["ARG_NAME"],
        "steps": [
          ...
        ]
        ...
      }
    }
      

    Der Block main akzeptiert ein einzelnes Argument, das der Name eines gültigen JSON-Datentyps ist, z. B. ein Array, ein Objekt oder ein String.

    Als Best Practice führt die Übergabe eines Objekts mit mehreren benannten Argumenten dazu, ist es einfacher, ihren Zweck zu verstehen und Argumente hinzuzufügen. Anschließend können Sie auch die Punktnotation verwenden, um auf die Argumente zuzugreifen.

    Andere untergeordnete Workflows können mehrere Argumente haben.

    Der folgende Workflow gibt beispielsweise eine "Hello"-Begrüßung an eine Person zurück, deren Vor- und Nachname als Laufzeitargumente übergeben wird:

    YAML

    main:
      params: [args]
      steps:
        - step1:
            assign:
              - outputVar: ${"Hello, " + args.firstName + " " + args.lastName + "!"}
        - step2:
            return: ${outputVar}

    JSON

    {
      "main": {
        "params": [
          "args"
        ],
        "steps": [
          {
            "step1": {
              "assign": [
                {
                  "outputVar": "${\"Hello \" + args.firstName + \" \" + args.lastName}"
                }
              ]
            }
          },
          {
            "step2": {
              "return": "${outputVar}"
            }
          }
        ]
      }
    }
      
  3. Stellen Sie Ihren Workflow bereit, um ihn zu erstellen oder zu aktualisieren.

Daten in einer Ausführungsanfrage übergeben

Sobald Ihr Workflow für den Empfang von Laufzeitargumenten eingerichtet ist, können Sie einen String übergeben im JSON-Format wie {"firstName":"Workflows","lastName":"User"} zum Workflow in einem Ausführungsanfrage.

Console

  1. Um einen Workflow auszuführen, gehen Sie in der Google Cloud Console zur Seite Workflows:

    Zur Seite "Workflows"

  2. Wählen Sie auf der Seite Workflows einen Workflow aus, der zum zugehörigen Detailseite.

  3. Klicken Sie auf der Seite Workflow-Details auf Ausführen.

  4. Geben Sie auf der Seite "Workflow ausführen" in den Bereich "Eingabe" einen JSON-String ein, der Ihre Parameternamen und Argumentwerte wie {"firstName":"Workflows","lastName":"User"} enthält:

    Eingabebereich mit dem JSON-Beispielstring

  5. Klicken Sie auf Ausführen.

    Auf der Seite Ausführungsdetails sehen Sie die Ergebnisse der Ausführung, einschließlich der Ausgabe Hello, Workflows User!, der Ausführungs-ID und des Ausführungsstatus sowie des aktuellen oder letzten Schritts der Workflowausführung. Weitere Informationen finden Sie unter Auf Ergebnisse der Workflowausführung zugreifen.

gcloud

Fügen Sie dem Befehl gcloud workflow execute das Flag --data hinzu, das Sie zum Ausführen Ihres Workflows verwenden. Dieses Flag verwendet einen JSON-String Ihrer Daten. So übergeben Sie beispielsweise firstName und lastName an den vorherigen Beispielworkflow:

gcloud workflows run WORKFLOW_NAME \
--data='{"firstName":"FIRST","lastName":"LAST"}'

Dabei gilt:

  • WORKFLOW_NAME: der Name des Workflows
  • FIRST: Der String, den Sie für firstName an Ihren Workflow übergeben möchten
  • LAST: Der String, den Sie für lastName an Ihren Workflow übergeben möchten

Die Ausgabe sollte in etwa so aussehen:

Waiting for execution [9379b067-306a-4db1-a58d-c9fc99aebfd4] to complete...done.
argument: '{"firstName":"Workflows","lastName":"User"}'
endTime: '2022-07-19T13:52:47.659199466Z'
name: projects/1051295516635/locations/us-central1/workflows/workflow-6/executions/9379b067-306a-4db1-a58d-c9fc99aebfd4
result: '"Hello, Workflows User!"'
startTime: '2022-07-19T13:52:47.623862835Z'
state: SUCCEEDED
status:
  currentSteps:
  - routine: main
    step: step2
workflowRevisionId: 000002-138

Clientbibliotheken

Je nach Sprache der Clientbibliothek können Sie ein Laufzeitargument in einer Ausführungsanfrage.

Beispiel mit JavaScript:

// Execute workflow
try {
  const createExecutionRes = await client.createExecution({
    parent: client.workflowPath(projectId, location, workflow),
    execution: {
      argument: JSON.stringify({"firstName":"Workflows","lastName":"User"})
    }
});
const executionName = createExecutionRes[0].name;

Oder mit Java:

// Creates the execution object.
CreateExecutionRequest request =
    CreateExecutionRequest.newBuilder()
        .setParent(parent.toString())
        .setExecution(Execution.newBuilder().setArgument("{\"firstName\":\"Workflows\",\"lastName\":\"User\"}").build())
        .build();

Weitere Informationen zum Ausführen eines Workflows mit den Google API-Clientbibliotheken finden Sie unter Workflow ausführen.

REST API

  1. Hängen Sie das Flag data an den Befehl an, den Sie zum Ausführen Ihres Workflows verwenden. Der Wert von data ist ein JSON-formatierter String mit einem Argument, dessen Wert ein oder mehrere Escape-Parameter-Wert-Paare ist. So übergeben Sie beispielsweise firstName und lastName an den vorherigen Beispielworkflow:

    curl --request POST \
       --header "Authorization: Bearer "$(gcloud auth application-default print-access-token) \
       --header 'Content-Type: application/json' \
       --data '{"argument":"{\"firstName\":\"FIRST\",\"lastName\":\"LAST\"}"}' \
       "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions"

    Ersetzen Sie Folgendes:

    • PROJECT_NUMBER: ist Ihre Google Cloud-Projektnummer.
    • WORKFLOW_NAME: der Name des Workflows
    • FIRST: Der String, den Sie für firstName an Ihren Workflow übergeben möchten
    • LAST: String, den Sie an Ihre Workflow für lastName

    Die Ausgabe sollte in etwa so aussehen:

    {
      "name": "projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions/EXECUTION_ID",
      "startTime": "2020-11-09T23:51:31.765761331Z",
      "state": "ACTIVE",
      "argument": "{\"firstName\":\"Workflows\",\"lastName\":\"User\"}",
      "workflowRevisionId": "000001-08c"
    }
     ```
    
  2. Führen Sie den folgenden Befehl aus, um die Ausführungsergebnisse abzurufen:

    curl --request GET \
       --header "Authorization: Bearer "$(gcloud auth application-default print-access-token) \
       --header 'Content-Type: application/json' \
       "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions/EXECUTION_ID"
    

    Ersetzen Sie EXECUTION_ID durch die ID aus der Ausgabe wird der erste Befehl zurückgegeben.

    Diese Ausgabe enthält Zeilen, die in etwa so aussehen:

    "argument": "{\"firstName\":\"Workflows\",\"lastName\":\"User\"}",
    "result": "\"Hello, Workflows User!\"",
    

Weitere Informationen zum Ausführen eines Workflows mit der REST API finden Sie unter Workflow ausführen.

Auf Laufzeitargumente zugreifen

In diesem Beispiel wird auf Laufzeitargumente zugegriffen, die im Rahmen der Ausführungsanfrage an den Workflow übergeben werden. Alle Argumente werden in derselben Zuordnung gespeichert, die als Parameter des Hauptworkflows deklariert sind.

Übergeben Sie bei diesem Workflow Laufzeitargumente im folgenden Format:

{"firstName":"Sherlock", "lastName":"Holmes"}

YAML

main:
  params: [args]
  steps:
    - step1:
        assign:
          - outputVar: ${"Hello " + args.firstName + " " + args.lastName}
    - step2:
        return: ${outputVar}

JSON

{
  "main": {
    "params": [
      "args"
    ],
    "steps": [
      {
        "step1": {
          "assign": [
            {
              "outputVar": "${\"Hello \" + args.firstName + \" \" + args.lastName}"
            }
          ]
        }
      },
      {
        "step2": {
          "return": "${outputVar}"
        }
      }
    ]
  }
}

Sie können default mit der Standardbibliotheksfunktion verwenden. map.get für den Zugriff optionale Laufzeitargumente und gibt einen Standardwert zurück, wenn der Schlüssel nicht gefunden. Im folgenden Beispiel wird northamerica-northeast1 verwendet, wenn region nicht angegeben ist:

YAML

  main:
      params: [input]
      steps:
      - init:
          assign:
            - region: ${default(map.get(input, "region"), "northamerica-northeast1")}
  

JSON

  {
    "main": {
      "params": [
        "input"
      ],
      "steps": [
        {
          "init": {
            "assign": [
              {
                "region": "${default(map.get(input, \"region\"), \"northamerica-northeast1\")}"
              }
            ]
          }
        }
      ]
    }
  }

Nächste Schritte