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.

Workflow-Status der Aufgabe

Ein Task-Zustand ("Type": "Task") steht für eine einzelne Arbeitseinheit, die von einem Zustandsautomaten durchgeführt wird. Eine Aufgabe erledigt Aufgaben mithilfe einer Aktivität oder einer AWS Lambda Funktion, durch Integration mit anderen unterstützten AWS-Services APIs oder durch Aufrufen einer HTTPS-API wie Stripe.

Die Sprache Amazon States stellt Aufgaben dar, indem sie den Typ eines Zustands auf setzt Task und der Aufgabe den Amazon-Ressourcennamen (ARN) der Aktivität, die Lambda-Funktion oder den HTTPS-API-Endpunkt zur Verfügung stellt.

Rufen Sie eine Funktion mit Argumenten auf JSONata

Die folgende Task-State-Definition (JSONata) ruft eine Lambda-Funktion mit dem Namen auf. priceWatcher

Beachten Sie die Verwendung von JSONata Ausdrücken zur Abfrage von Eingabedaten zur Verwendung in Arguments und des Aufgabenergebnisses im Zuweisungsfeld.

"Get Current Price": {
  "Type": "Task",
  "QueryLanguage" : "JSONata",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Next": "Check Price",
  "Arguments": {
    "Payload": {
    "product": "{% $states.context.Execution.Input.product %}"
    },
    "FunctionName": "arn:aws:lambda:<region>:account-id:function:priceWatcher:$LATEST"
  },
  "Assign": {
    "currentPrice": "{% $states.result.Payload.current_price %}"
  }
}

Rufen Sie eine Funktion mit JSONPath Parametern auf

Die folgende Task-State-Definition (JSONPath) ruft eine Lambda-Funktion mit dem Namen auf. HelloFunction

"Lambda Invoke": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:region:account-id:function:HelloFunction:$LATEST"
  },
  "End": true
}

Aufgabentypen

Step Functions unterstützt die folgenden Aufgabentypen, die Sie in einer Aufgabenstatusdefinition angeben können:

Sie geben einen Aufgabentyp an, indem Sie seinen ARN im Resource Feld einer Aufgabenstatusdefinition angeben. Das folgende Beispiel zeigt die Syntax des Resource Felds. Alle Task-Typen außer dem, der eine HTTPS-API aufruft, verwenden die folgende Syntax. Hinweise zur Syntax des HTTP-Tasks finden Sie unterRufen Sie HTTPS APIs in Step Functions Functions-Workflows auf.

Ersetzen Sie in Ihrer Aufgabenstatusdefinition den kursiv geschriebenen Text in der folgenden Syntax durch die AWS ressourcenspezifischen Informationen.

arn:partition:service:region:account:task_type:name

In der folgenden Liste werden die einzelnen Komponenten dieser Syntax erklärt:

In den folgenden Abschnitten erhalten Sie weitere Informationen zu den einzelnen Aufgabentypen.

Aktivität

Aktivitäten repräsentieren Worker (Prozesse oder Threads), die von Ihnen implementiert und gehostet werden, die eine bestimmte Aufgabe ausführen. Sie werden nur von Standard-Workflows und nicht von Express-Workflows unterstützt.

Activity Resource ARNs verwendet die folgende Syntax.

arn:partition:states:region:account:activity:name

Weitere Informationen zum Erstellen einer Aktivität und zum Implementieren von Workern finden Sie unter Activities.

Lambda-Funktionen

Lambda-Aufgaben führen eine Funktion aus mit AWS Lambda. Um eine Lambda-Funktion anzugeben, verwenden Sie den ARN der Lambda-Funktion im Resource Feld.

Die Form Ihres Resource Lambda-Funktionsfeldes hängt von der Art der Integration ab.

Bei einer AWS Standard-SDK-Integration mit einer Lambda-Funktion enthält das Resource Feld den folgenden Wert:

"arn:aws:states:::aws-sdk:lambda:invoke"

Wir empfehlen, die optimierte Integration für Ihre Lambda-Funktionen zu verwenden und den folgenden Wert für das Resource Feld zu verwenden:

"arn:aws:states:::lambda:invoke"

Die folgende Task Zustandsdefinition zeigt ein Beispiel für eine optimierte Integration mit einer Lambda-Funktion namens HelloWorld using JSONata.

"Optimized call to Lambda function (JSONata)": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Output": "{% $states.result.Payload %}",
      "Arguments": {
        "FunctionName": "arn:aws:lambda:region:account-id:function:HelloWorld:$LATEST",
        "Payload": {
          "key": "{% $states.input.myKey %}"
        }
      },
  "Next": "NextState"
}

Ein unterstützter AWS-Service

Wenn Sie auf eine verbundene Ressource verweisen, ruft Step Functions direkt die API-Aktionen eines unterstützten Dienstes auf. Geben Sie im Resource-Feld den Service und die Aktion an.

Der verbundene Dienst Resource ARNs verwendet die folgende Syntax.

arn:partition:states:region:account-id:servicename:APIname

Zum Beispiel:

{
 "StartAt": "BATCH_JOB",
 "States": {
   "BATCH_JOB": {
     "Type": "Task",
     "Resource": "arn:aws:states:::batch:submitJob.sync",
     "Parameters": {  
       "JobDefinition": "preprocessing",
       "JobName": "PreprocessingBatchJob",
       "JobQueue": "SecondaryQueue",
       "Parameters.$": "$.batchjob.parameters",
       "RetryStrategy": {
          "attempts": 5
        }
     },
     "End": true
    }
  }
}

Felder für den Aufgabenstatus

Zusätzlich zu den allgemeinen Zustandsfeldern haben Task-Zustände die folgenden Felder.

Ein Task-Zustand muss entweder das Feld End auf true setzen, wenn der Zustand die Ausführung beendet, oder einen Zustand im Feld Next bereitstellen, der nach Abschluss des Task-Zustands ausgeführt wird.

Beispiele für die Definition von Aufgabenstatus

Die folgenden Beispiele zeigen, wie Sie die Definition des Aufgabenstatus entsprechend Ihren Anforderungen angeben können.

Timeouts und Heartbeat-Intervalle für den Aufgabenstatus

Es ist ein bewährtes Verfahren, für langlebige Aktivitäten einen Timeout-Wert und ein Heartbeat-Intervall festzulegen. Dies kann durch Angabe der Timeout- und Heartbeat-Werte oder durch dynamische Einstellung erreicht werden.

Beispiel für ein statisches Timeout und eine Heartbeat-Benachrichtigung

Wenn HelloWorld abgeschlossen ist, wird der nächste Zustand (hier NextState genannt) ausgeführt.

Wenn diese Aufgabe nicht innerhalb von 300 Sekunden abgeschlossen ist oder keine Heartbeat-Benachrichtigungen in Intervallen von 60 Sekunden sendet, wird die Aufgabe als failed gekennzeichnet.

"ActivityState": {
  "Type": "Task",
  "Resource": "arn:aws:states:region:123456789012:activity:HelloWorld",
  "TimeoutSeconds": 300,
  "HeartbeatSeconds": 60,
  "Next": "NextState"
}

Beispiel für ein dynamisches Task-Timeout und eine Heartbeat-Benachrichtigung

In diesem Beispiel wird nach Abschluss des AWS Glue Auftrags der nächste Status ausgeführt.

Wenn diese Aufgabe nicht innerhalb des vom AWS Glue Job dynamisch festgelegten Intervalls abgeschlossen werden kann, wird die Aufgabe als markiertfailed.

"GlueJobTask": {
  "Type": "Task",
  "Resource": "arn:aws:states:::glue:startJobRun.sync",
  "Parameters": {
    "JobName": "myGlueJob"
  },
  "TimeoutSecondsPath": "$.params.maxTime",
  "Next": "NextState"
}

Beispiele für das Feld „Anmeldeinformationen“ des Aufgabenstatus

Festcodierte IAM-Rollen-ARN angeben

Das folgende Beispiel spezifiziert eine Ziel-IAM-Rolle, die die Ausführungsrolle einer Zustandsmaschine annehmen muss, um auf eine kontoübergreifende Lambda-Funktion mit dem Namen zuzugreifen. Echo In diesem Beispiel wird der ARN der Zielrolle als hartcodierter Wert angegeben.

{
  "StartAt": "Cross-account call",
  "States": {
    "Cross-account call": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn": "arn:aws:iam::111122223333:role/LambdaRole"
      },
      "Parameters": {
        "FunctionName": "arn:aws:lambda:us-east-2:111122223333:function:Echo"
      },
      "End": true
    }
  }
}

ARN JSONPath als IAM-Rolle angeben

Im folgenden Beispiel wird ein JSONPath Wert angegeben, der zur Laufzeit in einen IAM-Rollen-ARN aufgelöst wird.

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "$.roleArn"
      },
      ...
    }
  }
}

Spezifizierung einer systemeigenen Funktion als IAM-Rollen-ARN

Im folgenden Beispiel wird die States.Formatsysteminterne Funktion verwendet, die zur Laufzeit in einen IAM-Rollen-ARN aufgelöst wird.

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "States.Format('arn:aws:iam::{}:role/ROLENAME', $.accountId)"
      },
      ...
    }
  }
}