Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Avvia una nuova macchina a AWS Step Functions stati da un'esecuzione in esecuzione
Step Functions si integra con la propria integrazione API come servizio. Scopri come usare Step Functions per avviare una nuova esecuzione di una macchina a stati direttamente dallo stato dell'attività di un'esecuzione in esecuzione. Durante la creazione di nuovi flussi di lavoro, utilizza le esecuzioni di flusso di lavoro nidificate per ridurre la complessità dei flussi di lavoro principali e riutilizzare i processi comuni.
Caratteristiche principali dell'integrazione Optimized Step Functions
Il modello di Esegui un processo (.sync) integrazione è disponibile.
Tieni presente che non ci sono ottimizzazioni per i modelli Richiesta e risposta di Attendi una richiamata con Task Token integrazione.
Per ulteriori informazioni, consulta gli argomenti seguenti:
Step Functions supportate APIs
-
-
Parametri supportati
Esempi di flussi di lavoro
Di seguito è incluso uno stato Task
che avvia l'esecuzione di un'altra macchina a stati e ne attende il completamento.
{
"Type":"Task",
"Resource":"arn:aws:states:::states:startExecution.sync:2",
"Parameters":{
"Input":{
"Comment": "Hello world!"
},
"StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld",
"Name":"ExecutionName"
},
"End":true
}
Di seguito è incluso uno stato Task
che avvia l'esecuzione di un'altra macchina a stati.
{
"Type":"Task",
"Resource":"arn:aws:states:::states:startExecution",
"Parameters":{
"Input":{
"Comment": "Hello world!"
},
"StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld",
"Name":"ExecutionName"
},
"End":true
}
L’esempio seguente include uno stato Task
che implementa il modello di integrazione del servizio di callback.
{
"Type":"Task",
"Resource":"arn:aws:states:::states:startExecution.waitForTaskToken",
"Parameters":{
"Input":{
"Comment": "Hello world!",
"token.$": "$$.Task.Token"
},
"StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld",
"Name":"ExecutionName"
},
"End":true
}
Per associare un'esecuzione nidificata del workflow all'esecuzione principale che l'ha avviata, passate un parametro con nome speciale che include l'ID di esecuzione estratto dall'oggetto Context. Quando si avvia un'esecuzione nidificata, utilizza un parametro denominato AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID
. Passa l'ID di esecuzione aggiungendolo .$
al nome del parametro e facendo riferimento all'ID nell'oggetto Context con. $$.Execution.Id
Per ulteriori informazioni, consulta Accesso all'oggetto Context.
{
"Type":"Task",
"Resource":"arn:aws:states:::states:startExecution.sync",
"Parameters":{
"Input":{
"Comment": "Hello world!",
"AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$": "$$.Execution.Id"
},
"StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld",
"Name":"ExecutionName"
},
"End":true
}
Le macchine a stato nidificato restituiscono quanto segue:
Risorsa | Output |
---|---|
startExecution.sync | Stringa |
startExecution.sync: 2 | JSON |
Entrambi attenderanno il completamento della macchina a stati nidificati, ma restituiscono formati Output
diversi. Ad esempio, se crei una funzione Lambda che restituisce l'oggetto{ "MyKey": "MyValue" }
, otterrai le seguenti risposte:
Per startExecution .sync:
{
<other fields>
"Output": "{ \"MyKey\": \"MyValue\" }"
}
Per startExecution .sync:2:
{
<other fields>
"Output": {
"MyKey": "MyValue"
}
}
Configurazione delle autorizzazioni IAM per le macchine a stati annidate
Una macchina a stati principale determina se una macchina a stati figlio ha completato l'esecuzione utilizzando polling ed eventi. Il polling richiede l'autorizzazione states:DescribeExecution
mentre gli eventi inviati EventBridge a Step Functions richiedono le autorizzazioni per events:PutTargets
events:PutRule
, e. events:DescribeRule
Se IAM nel ruolo dell'utente mancano queste autorizzazioni, potrebbe verificarsi un ritardo prima che una macchina a stati principale venga a conoscenza del completamento dell'esecuzione della macchina a stati secondari.
Per una macchina a stati che chiama StartExecution
per una singola esecuzione di flusso di lavoro nidificata, viene utilizzata una policy IAM che limita le autorizzazioni alla macchina a stati.
Per ulteriori informazioni, consulta le IAMautorizzazioni per Step Functions.
IAMpolitiche per chiamare i flussi di lavoro Step Functions annidati
Per una macchina a stati che chiama StartExecution
per una singola esecuzione di flusso di lavoro nidificata, viene utilizzata una policy IAM che limita le autorizzazioni alla macchina a stati.
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"states:StartExecution"
],
"Resource": [
"arn:aws:states:[[region]]
:[[accountId]]
:stateMachine:[[stateMachineName]]
"
]
}
]
}
Per ulteriori informazioni, consulta gli argomenti seguenti:
Per ulteriori informazioni sulle esecuzioni di flussi di lavoro nidificati, consulta Avvia le esecuzioni del flusso di lavoro da uno stato di attività in Step Functions.