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à.
Esempio di orchestrazione Lambda
Questo progetto di esempio dimostra come integrare AWS Lambda le funzioni nelle macchine a stati Step Functions.
In questo progetto, Step Functions utilizza le funzioni Lambda per controllare il prezzo di un'azione e determinare una raccomandazione commerciale di acquisto o vendita. L'utente riceve quindi questa raccomandazione e può scegliere se acquistare o vendere il titolo. Il risultato dello scambio viene restituito utilizzando un argomento SNS.
Per ulteriori informazioni sulle integrazioni dei servizi Step Functions, consulta quanto segue:
-
Politiche IAM per:
Nota
Questo progetto di esempio potrebbe comportare costi.
Per i nuovi AWS utenti, è disponibile un livello di utilizzo gratuito. In questo piano, i servizi sono gratuiti al di sotto di un determinato livello di utilizzo. Per ulteriori informazioni sui AWS costi e sul piano gratuito, consulta la sezione Prezzi
Fase 1: Creare la macchina a stati e fornire risorse
-
Apri la console Step Functions
e scegli Crea macchina a stati. -
Digita
Orchestrate Lambda functionsnella casella di ricerca, quindi scegli Orchestrate Lambda functions dai risultati di ricerca restituiti. -
Seleziona Successivo per continuare.
-
Step Functions elenca quelli Servizi AWS utilizzati nel progetto di esempio selezionato. Mostra anche un grafico del flusso di lavoro per il progetto di esempio. Implementa questo progetto sul tuo Account AWS o usalo come punto di partenza per creare i tuoi progetti. In base a come vuoi procedere, scegli Esegui una demo o Sviluppa su di essa.
Questo progetto di esempio utilizza le seguenti risorse:
-
Cinque funzioni Lambda
-
Una coda Amazon Simple Queue Service
-
Un argomento Amazon Simple Notification Service
-
Una macchina a stati AWS Step Functions
-
Ruoli AWS Identity and Access Management (IAM) correlati
L'immagine seguente mostra il grafico del flusso di lavoro per il progetto di esempio delle Lambdafunzioni di Orchestrate:
-
-
Scegli Usa modello per continuare con la selezione.
-
Esegui una di queste operazioni:
-
Se hai selezionato Build on it, Step Functions crea il prototipo del flusso di lavoro per il progetto di esempio selezionato. Step Functions non distribuisce le risorse elencate nella definizione del flusso di lavoro.
In Workflow StudioModalità di progettazione, trascina gli stati da e continua Stati del browser a creare il tuo prototipo di flusso di lavoro. Oppure passa a Modalità codice quello che fornisce un editor di codice integrato simile a VS Code per aggiornare la definizione Amazon States Language (ASL) della tua macchina a stati all'interno della console Step Functions. Per ulteriori informazioni sull'utilizzo di Workflow Studio per creare macchine a stati, consultaUtilizzo di Workflow Studio.
-
Se hai selezionato Esegui una demo, Step Functions crea un progetto di esempio di sola lettura che utilizza un AWS CloudFormation modello per distribuire le AWS risorse elencate in quel modello sul tuo. Account AWS
Suggerimento
Per visualizzare la definizione della macchina a stati del progetto di esempio, scegli Code.
Quando sei pronto, scegli Distribuisci ed esegui per distribuire il progetto di esempio e creare le risorse.
La creazione di queste risorse e delle relative autorizzazioni IAM può richiedere fino a 10 minuti. Durante la distribuzione delle risorse, puoi aprire il link CloudFormation Stack ID per vedere quali risorse vengono fornite.
Dopo aver creato tutte le risorse del progetto di esempio, puoi vedere il nuovo progetto di esempio elencato nella pagina State machines.
Importante
Potrebbero essere applicate tariffe standard per ogni servizio utilizzato nel CloudFormation modello.
-
Fase 2: Eseguire la macchina a stati
Dopo aver fornito e distribuito tutte le risorse, viene visualizzata la finestra di dialogo Avvia esecuzione.
-
Nella pagina State machines, scegliete il vostro progetto di esempio.
-
Nella pagina del progetto di esempio, scegli Avvia esecuzione.
-
Nella finestra di dialogo Avvia esecuzione, effettuate le seguenti operazioni:
-
(Facoltativo) Per identificare l'esecuzione, potete specificarne un nome nella casella Nome. Per impostazione predefinita, Step Functions genera automaticamente un nome di esecuzione univoco.
Nota
Step Functions consente di creare nomi per macchine a stati, esecuzioni e attività ed etichette che contengono caratteri non ASCII. Questi nomi non ASCII non funzionano con Amazon. CloudWatch Per assicurarti di poter tenere traccia delle CloudWatch metriche, scegli un nome che utilizzi solo caratteri ASCII.
-
(Facoltativo) Nella casella Input, inserisci i valori di input in formato JSON per eseguire il flusso di lavoro.
Se avete scelto di eseguire una demo, non è necessario fornire alcun input di esecuzione.
Nota
Se il progetto demo che hai distribuito contiene dati di input di esecuzione precompilati, usa quell'input per eseguire la macchina a stati.
-
Selezionare Start execution (Avvia esecuzione).
-
La console Step Functions ti indirizza a una pagina intitolata con il tuo ID di esecuzione. Questa pagina è nota come pagina dei dettagli di esecuzione. In questa pagina è possibile esaminare i risultati dell'esecuzione man mano che l'esecuzione procede o dopo il suo completamento.
Per esaminare i risultati dell'esecuzione, scegliete i singoli stati nella vista Grafico, quindi scegliete le singole schede Dettagli del passaggio nel riquadro per visualizzare i dettagli di ogni stato, inclusi rispettivamente input, output e definizione. Per i dettagli sulle informazioni sull'esecuzione che è possibile visualizzare nella pagina Dettagli di esecuzione, vederePagina dei dettagli di esecuzione: panoramica dell'interfaccia.
-
Informazioni sulla macchina a stati e sulla sua esecuzione
La macchina a stati di questo progetto di esempio si integra AWS Lambda passando i parametri direttamente a tali risorse, utilizza una coda Amazon SQS per gestire la richiesta di approvazione umana e utilizza un argomento Amazon SNS per restituire i risultati della query.
Un'esecuzione di Step Functions riceve un testo JSON come input e lo passa al primo stato del flusso di lavoro. I singoli stati ricevono i dati JSON come input e in genere passano i dati JSON come output allo stato successivo. In questo progetto di esempio, l'output di ogni passaggio viene passato come input alla fase successiva del flusso di lavoro. Ad esempio, la fase di raccomandazione Generate Buy/Sell riceve come input l'output della fase Check Stock Price. Inoltre, l'output della fase di raccomandazione Generate Buy/Sell viene passato come input alla fase successiva, Request Human Approval, che simula una fase di approvazione umana.
Nota
Per visualizzare l'output restituito da un passaggio e l'input passato a un passaggio, apri la pagina Dettagli di esecuzione per l'esecuzione del flusso di lavoro. Nella sezione Dettagli del passaggio, visualizza l'input e l'output per ogni passaggio selezionato nella modalità Visualizza.
Per implementare una fase di approvazione umana, in genere si sospende l'esecuzione del flusso di lavoro fino alla restituzione di un token di attività. In questo progetto di esempio, un messaggio viene passato a una coda Amazon SQS, che viene utilizzata come trigger per la funzione Lambda definita per gestire la funzionalità di callback. Il messaggio contiene un token di attività e l'output restituito dal passaggio precedente. La funzione Lambda viene richiamata con il payload del messaggio. L'esecuzione del flusso di lavoro viene sospesa fino a quando non riceve il token dell'attività con una chiamata API. SendTaskSuccess Per ulteriori informazioni sui task token, consulta. Attendere un callback con il token dell’attività
Il codice seguente per la StepFunctionsSample-HelloLambda-ApproveSqsLambda funzione mostra come viene definita l'approvazione automatica di qualsiasi attività inviata dalla coda di Amazon SQS tramite la macchina a stati Step Functions.
exports.lambdaHandler = (event, context, callback) => {
const stepfunctions = new aws.StepFunctions();
// For every record in sqs queue
for (const record of event.Records) {
const messageBody = JSON.parse(record.body);
const taskToken = messageBody.TaskToken;
const params = {
output: "\"approved\"",
taskToken: taskToken
};
console.log(`Calling Step Functions to complete callback task with params ${JSON.stringify(params)}`);
// Approve
stepfunctions.sendTaskSuccess(params, (err, data) => {
if (err) {
console.error(err.message);
callback(err.message);
return;
}
console.log(data);
callback(null);
});
}
};Sfoglia questo esempio di macchina a stati per vedere come Step Functions controlla Lambda e Amazon SQS.
Per ulteriori informazioni su come AWS Step Functions controllare altri AWS servizi, consulta. Utilizzo AWS Step Functions con altri servizi
{
"StartAt": "Check Stock Price",
"States": {
"Check Stock Price": {
"Type": "Task",
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLam-CheckStockPriceLambda-444455556666",
"Next": "Generate Buy/Sell recommendation"
},
"Generate Buy/Sell recommendation": {
"Type": "Task",
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-Hello-GenerateBuySellRecommend-123456789012",
"ResultPath": "$.recommended_type",
"Next": "Request Human Approval"
},
"Request Human Approval": {
"Type": "Task",
"Resource": "arn:aws:states:::sqs:sendMessage.waitForTaskToken",
"Parameters": {
"QueueUrl": "https://sqs.us-west-1.amazonaws.com/111122223333/StepFunctionsSample-HelloLambda4444-5555-6666-RequestHumanApprovalSqs-777788889999",
"MessageBody": {
"Input.$": "$",
"TaskToken.$": "$$.Task.Token"
}
},
"ResultPath": null,
"Next": "Buy or Sell?"
},
"Buy or Sell?": {
"Type": "Choice",
"Choices": [
{
"Variable": "$.recommended_type",
"StringEquals": "buy",
"Next": "Buy Stock"
},
{
"Variable": "$.recommended_type",
"StringEquals": "sell",
"Next": "Sell Stock"
}
]
},
"Buy Stock": {
"Type": "Task",
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-BuyStockLambda-000000000000",
"Next": "Report Result"
},
"Sell Stock": {
"Type": "Task",
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-SellStockLambda-111111111111",
"Next": "Report Result"
},
"Report Result": {
"Type": "Task",
"Resource": "arn:aws:states:::sns:publish",
"Parameters": {
"TopicArn": "arn:aws:sns:us-west-1:111122223333:StepFunctionsSample-HelloLambda1111-2222-3333-ReportResultSnsTopic-222222222222",
"Message": {
"Input.$": "$"
}
},
"End": true
}
}
}Per informazioni su come configurare IAM quando si utilizza Step Functions con altri AWS servizi, vederePolitiche IAM per servizi integrati.
Esempi IAM
Questi esempi di policy AWS Identity and Access Management (IAM) generati dal progetto di esempio includono il minimo privilegio necessario per eseguire la macchina a stati e le risorse correlate. Ti consigliamo di includere solo le autorizzazioni necessarie nelle tue policy IAM.
{
"Statement": [
{
"Action": [
"lambda:InvokeFunction"
],
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLam-CheckStockPriceLambda-444455556666",
"Effect": "Allow"
}
]
}{
"Statement": [
{
"Action": [
"lambda:InvokeFunction"
],
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-Hello-GenerateBuySellRecommend-123456789012",
"Effect": "Allow"
}
]
}{
"Statement": [
{
"Action": [
"lambda:InvokeFunction"
],
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-BuyStockLambda-777788889999",
"Effect": "Allow"
}
]
}{
"Statement": [
{
"Action": [
"lambda:InvokeFunction"
],
"Resource": "arn:aws:lambda:us-west-1:111122223333:function:StepFunctionsSample-HelloLambda-SellStockLambda-000000000000",
"Effect": "Allow"
}
]
}{
"Statement": [
{
"Action": [
"sqs:SendMessage*"
],
"Resource": "arn:aws:sqs:us-west-1:111122223333:StepFunctionsSample-HelloLambda4444-5555-6666-RequestHumanApprovalSqs-111111111111",
"Effect": "Allow"
}
]
}{
"Statement": [
{
"Action": [
"sns:Publish"
],
"Resource": "arn:aws:sns:us-west-1:111122223333:StepFunctionsSample-HelloLambda1111-2222-3333-ReportResultSnsTopic-222222222222",
"Effect": "Allow"
}
]
}Per informazioni su come configurare IAM quando si utilizza Step Functions con altri AWS servizi, vederePolitiche IAM per servizi integrati.
