Pour vous aider à passer d'Amazon Web Services (AWS) Step Functions aux workflows sur Google Cloud, cette page explique les principales similitudes et différences entre les deux produits. Ces informations sont destinées à aider les personnes qui connaissent déjà Step Functions à implémenter une architecture similaire à l'aide de workflows.
Comme Step Functions, Workflows est une plate-forme d'orchestration entièrement gérée, basée sur l'état, qui exécute des services dans l'ordre que vous définissez: un workflow. Ces workflows peuvent combiner des services tels que des services personnalisés hébergés sur Cloud Run ou Cloud Run Functions, des services Google Cloud tels que Cloud Vision AI et BigQuery, ainsi que toute API HTTP.
Notez que les workflows Express Step Functions sont un type de workflow AWS Step Functions qui n'est pas pris en compte ici, car la durée d'un workflow Express est limitée et l'exécution d'un workflow "une seule fois" n'est pas prise en charge.
Hello world
Dans Step Functions, une machine à états est un workflow, et une tâche est un état dans un workflow qui représente une unité de travail unique effectuée par un autre service AWS. Step Functions exige que chaque état définisse l'état suivant.
Dans Workflows, une série d'étapes utilisant la syntaxe Workflows décrit les tâches à exécuter. Workflows traite les étapes comme si elles se trouvaient dans une liste ordonnée et les exécute une par une jusqu'à ce que toutes les étapes soient exécutées.
L'exemple "Hello World" suivant illustre l'utilisation des états dans les fonctions d'étape et des étapes dans les workflows:
Fonctions en escalier
{ "Comment": "Hello world example of Pass states in Amazon States Language", "StartAt": "Hello", "States": { "Hello": { "Type": "Pass", "Result": "Hello", "Next": "World" }, "World": { "Type": "Pass", "Result": "World", "End": true } } }
Fichier YAML des workflows
--- # Hello world example of steps using Google Cloud Workflows syntax main: steps: - Hello: next: World - World: next: end ...
JSON des workflows
{ "main": { "steps": [ { "Hello": { "next": "World" } }, { "World": { "next": "end" } } ] } }
Présentation de la comparaison
Cette section compare les deux produits plus en détail.
| Fonctions en escalier | Workflows | |
|---|---|---|
| Syntaxe | JSON (YAML dans les outils) | YAML ou JSON |
| Flux de contrôle | Transitions entre les états | Contrôle de flux impératif avec étapes |
| Worker | Ressources (ARN) et tâche HTTP | Requêtes HTTP et connecteurs |
| Fiabilité | Attraper/Réessayer | Attraper/Réessayer |
| Parallélisme | Compatible | Compatible |
| Données d'état | L'état est transmis | Variables Workflows |
| Authentification | IAM | IAM |
| Expérience utilisateur | Workflow Studio, CLI, SDK, IaC | Console Google Cloud, CLI, SDK, IaC |
| Tarifs | Tarifs de Step Functions | Tarifs de Workflows |
- Syntaxe
Step Functions utilise principalement le format JSON pour définir des fonctions et n'est pas compatible directement avec le format YAML. Toutefois, dans AWS Toolkit pour Visual Studio Code et dans AWS CloudFormation, vous pouvez utiliser le format YAML pour une définition Step Functions.
Vous pouvez décrire les étapes de Workflows à l'aide de la syntaxe Workflows. Elles peuvent être écrites en YAML ou en JSON. La plupart des workflows sont au format YAML. Les exemples de cette page illustrent les avantages de YAML, y compris la facilité de lecture et d'écriture, ainsi que la prise en charge native des commentaires. Pour obtenir une explication détaillée de la syntaxe Workflows, consultez la documentation de référence sur la syntaxe.
- Flux de contrôle
Workflows et Step Functions modélisent les workflows en tant que série de tâches: étapes dans Workflows et états dans Step Functions. Les deux permettent à une tâche d'indiquer la tâche à exécuter ensuite et acceptent les conditions similaires à un commutateur pour sélectionner l'unité de travail suivante en fonction de l'état actuel. Une différence clé est que Step Functions nécessite que chaque état définisse le suivant, tandis que Workflows exécute les étapes dans l'ordre dans lequel elles sont spécifiées (y compris les étapes suivantes alternatives). Pour en savoir plus, consultez les Conditions et les Étapes.
- Nœud de calcul
Les deux produits orchestrent des ressources de calcul telles que des fonctions, des conteneurs et d'autres services Web pour accomplir des tâches. Dans Step Functions, le nœud de calcul est identifié par un champ
Resource, qui est syntaxiquement un URI. Les URI utilisés pour identifier les ressources de worker sont au format de nom de ressource Amazon (ARN). Pour appeler directement un point de terminaison HTTP arbitraire, vous pouvez définir une tâche HTTP.Les workflows peuvent envoyer des requêtes HTTP à un point de terminaison HTTP arbitraire et obtenir une réponse. Les connecteurs facilitent la connexion à d'autres API Google Cloud au sein d'un workflow et l'intégration de vos workflows à d'autres produits Google Cloud tels que Pub/Sub, BigQuery ou Cloud Build. Les connecteurs simplifient les services d'appel, car ils gèrent la mise en forme des requêtes à votre place, en fournissant des méthodes et des arguments pour que vous n'ayez pas besoin de connaître les détails d'une API Google Cloud. Vous pouvez également configurer les stratégies de délai avant expiration et d'interrogation.
- Fiabilité
Si une tâche échoue, votre workflow doit pouvoir la relancer de manière appropriée, intercepter les exceptions lorsqu'il le doit et rediriger le workflow si nécessaire. Les fonctions d'étape et les workflows atteignent la fiabilité à l'aide de mécanismes similaires: détection des exceptions avec des nouvelles tentatives et distribution éventuelle ailleurs dans le workflow. Pour en savoir plus, consultez la section Erreurs de workflow.
- Parallélisme
Vous pouvez souhaiter que votre workflow orchestre plusieurs tâches en parallèle. Les fonctions d'étape offrent deux façons d'y parvenir: vous pouvez prendre un élément de données et le transmettre en parallèle à plusieurs tâches différentes, ou vous pouvez utiliser un tableau et transmettre ses éléments à la même tâche.
Dans les workflows, vous pouvez définir une partie de votre workflow dans laquelle deux étapes ou plus peuvent s'exécuter simultanément. Vous pouvez définir des branches qui s'exécutent simultanément ou une boucle dans laquelle les itérations s'exécutent simultanément. Pour en savoir plus, consultez la section Exécuter les étapes du workflow en parallèle.
- Données d'état
L'un des avantages d'un moteur de workflow est que les données d'état sont gérées pour vous sans datastore externe. Dans Step Functions, les données d'état sont transmises d'un état à un autre dans une structure JSON.
Dans Workflows, vous pouvez enregistrer les données d'état dans des variables globales. Étant donné que la durée d'exécution est limitée à un an, vous pouvez conserver les données d'état tant que l'instance est en cours d'exécution.
- Authentification
Les deux produits reposent sur un système sous-jacent de Identity and Access Management (IAM) pour l'authentification et le contrôle des accès. Par exemple, vous pouvez utiliser un rôle IAM pour appeler des fonctions de séquence.
Dans Workflows, vous pouvez utiliser un compte de service pour appeler un workflow. Vous pouvez utiliser OAuth 2.0 ou OIDC pour vous connecter aux API Google Cloud. Vous pouvez également utiliser un en-tête de requête d'autorisation pour vous authentifier auprès d'une API tierce. Pour en savoir plus, consultez les pages Accorder à un workflow l'autorisation d'accéder aux ressources Google Cloud et Effectuer des requêtes authentifiées à partir d'un workflow.
- Expérience utilisateur
Vous pouvez utiliser un outil de ligne de commande ou une infrastructure en tant que code (IAC) telle que Terraform pour définir et gérer à la fois des fonctions de séquence et des workflows.
De plus, Workflows prend en charge l'exécution de workflows à l'aide des bibliothèques clientes, dans la console Google Cloud, à l'aide de la Google Cloud CLI ou en envoyant une requête à l'API REST Workflows. Pour en savoir plus, consultez la page Exécuter un workflow.
- Tarifs
Les deux produits proposent une version gratuite. Pour en savoir plus, consultez les pages de tarification respectives: Tarifs de Step Functions et Tarifs de Workflows.
Mappage des types d'états sur les étapes
Step Functions propose huit types d'états. Les états sont des éléments d'une machine à états qui peuvent prendre des décisions en fonction de leurs entrées, effectuer des actions et transmettre des sorties à d'autres états. Avant de migrer de Step Functions vers Workflows, assurez-vous de savoir comment traduire chaque type d'état en étape Workflows.
Choice
Un état Choice ajoute une logique de branchement à une machine à états.
Dans les workflows, vous pouvez utiliser un bloc switch en tant que mécanisme de sélection qui permet à la valeur d'une expression de contrôler le flux d'exécution d'un workflow. Si une valeur correspond, l'instruction de cette condition est exécutée.
Pour en savoir plus, consultez la section Conditions.
Fonctions en escalier
"ChoiceState": { "Type": "Choice", "Choices": [ { "Variable": "$.foo", "NumericEquals": 1, "Next": "FirstMatchState" }, { "Variable": "$.foo", "NumericEquals": 2, "Next": "SecondMatchState" } ], "Default": "DefaultState" }
Fichier YAML des workflows
switch: - condition: ${result.body.SomeField < 10} next: small - condition: ${result.body.SomeField < 100} next: medium - condition: true next: default_step
JSON des workflows
{ "switch": [ { "condition": "${result.body.SomeField < 10}", "next": "small" }, { "condition": "${result.body.SomeField < 100}", "next": "medium" }, { "condition": true, "next": "default_step" } ] }
Fail
Un état Fail arrête l'exécution de la machine d'état et la marque comme échec.
Dans Workflows, vous pouvez générer des erreurs personnalisées à l'aide de la syntaxe raise, et vous pouvez intercepter et gérer les erreurs à l'aide d'un bloc try/except. Pour en savoir plus, consultez la section Générer des erreurs.
Fonctions en escalier
"FailState": { "Type": "Fail", "Error": "ErrorA", "Cause": "Kaiju attack" }
Fichier YAML des workflows
raise: code: 55 message: "Something went wrong."
JSON des workflows
{ "raise": { "code": 55, "message": "Something went wrong." } }
Map
Un état Map peut être utilisé pour exécuter un ensemble d'étapes pour chaque élément d'un tableau d'entrée.
Dans Workflows, vous pouvez utiliser des boucles for pour les iterations.
Fonctions en escalier
{ "StartAt": "ExampleMapState", "States": { "ExampleMapState": { "Type": "Map", "Iterator": { "StartAt": "CallLambda", "States": { "CallLambda": { "Type": "Task", "Resource": "arn:aws:lambda:us-east-1:123456789012:function:HelloFunction", "End": true } } }, "End": true } } }
Fichier YAML des workflows
- assignStep: assign: - map: 1: 10 2: 20 3: 30 - sum: 0 - loopStep: for: value: key in: ${keys(map)} steps: - sumStep: assign: - sum: ${sum + map[key]} - returnStep: return: ${sum}
JSON des workflows
[ { "assignStep": { "assign": [ { "map": { "1": 10, "2": 20, "3": 30 } }, { "sum": 0 } ] } }, { "loopStep": { "for": { "value": "key", "in": "${keys(map)}", "steps": [ { "sumStep": { "assign": [ { "sum": "${sum + map[key]}" } ] } } ] } } }, { "returnStep": { "return": "${sum}" } } ]
Parallel
Un état Parallel peut être utilisé pour créer des branches d'exécution parallèles dans votre machine à états. Dans l'exemple Step Functions suivant, une recherche d'adresse et de numéro de téléphone est effectuée en parallèle.
Dans Workflows, vous pouvez utiliser une étape parallel pour définir une partie de votre workflow dans laquelle deux étapes ou plus peuvent s'exécuter simultanément. Pour en savoir plus, consultez la section Étapes parallèles.
Fonctions en escalier
{ "StartAt": "LookupCustomerInfo", "States": { "LookupCustomerInfo": { "Type": "Parallel", "End": true, "Branches": [ { "StartAt": "LookupAddress", "States": { "LookupAddress": { "Type": "Task", "Resource": "arn:aws:lambda:us-east-1:123456789012:function:AddressFinder", "End": true } } }, { "StartAt": "LookupPhone", "States": { "LookupPhone": { "Type": "Task", "Resource": "arn:aws:lambda:us-east-1:123456789012:function:PhoneFinder", "End": true } } } ] } } }
Fichier YAML des workflows
main: params: [args] steps: - init: assign: - workflow_id: "lookupAddress" - customer_to_lookup: - address: ${args.customerId} - phone: ${args.customerId} - addressed: ["", ""] # to write to this variable, you must share it - parallel_address: parallel: shared: [addressed] for: in: ${customer_to_lookup} index: i # optional, use if index is required value: arg steps: - address: call: googleapis.workflowexecutions.v1.projects.locations.workflows.executions.run args: workflow_id: ${workflow_id} argument: ${arg} result: r - set_result: assign: - addressed[i]: ${r} - return: return: ${addressed}
JSON des workflows
{ "main": { "params": [ "args" ], "steps": [ { "init": { "assign": [ { "workflow_id": "lookupAddress" }, { "customer_to_lookup": [ { "address": "${args.customerId}" }, { "phone": "${args.customerId}" } ] }, { "addressed": [ "", "" ] } ] } }, { "parallel_address": { "parallel": { "shared": [ "addressed" ], "for": { "in": "${customer_to_lookup}", "index": "i", "value": "arg", "steps": [ { "address": { "call": "googleapis.workflowexecutions.v1.projects.locations.workflows.executions.run", "args": { "workflow_id": "${workflow_id}", "argument": "${arg}" }, "result": "r" } }, { "set_result": { "assign": [ { "addressed[i]": "${r}" } ] } } ] } } } }, { "return": { "return": "${addressed}" } } ] } }
Pass
Un état Pass transmet son entrée à sa sortie, sans effectuer de travail. Cette méthode est couramment utilisée pour manipuler les données d'état dans le fichier JSON.
Comme Workflows ne transmet pas de données de cette manière, vous pouvez laisser l'état sans action ou utiliser une étape d'attribution pour modifier les variables. Pour en savoir plus, consultez la section Attribuer des variables.
Fonctions en escalier
"No-op": { "Type": "Pass", "Result": { "x-datum": 0.38, "y-datum": 622.22 }, "ResultPath": "$.coords", "Next": "End" }
Fichier YAML des workflows
assign: - number: 5 - number_plus_one: ${number+1} - other_number: 10 - string: "hello"
JSON des workflows
{ "assign": [ { "number": 5 }, { "number_plus_one": "${number+1}" }, { "other_number": 10 }, { "string": "hello" } ] }
Réussir
Un état Succeed arrête une exécution.
Dans les workflows, vous pouvez utiliser return dans le workflow principal pour arrêter l'exécution d'un workflow. Vous pouvez également terminer un workflow en effectuant la dernière étape (en supposant que l'étape ne saute pas vers une autre), ou utiliser next: end pour arrêter l'exécution d'un workflow si vous n'avez pas besoin de renvoyer une valeur.
Pour en savoir plus, consultez la section Achever l'exécution d'un workflow.
Fonctions en escalier
"SuccessState": { "Type": "Succeed" }
Fichier YAML des workflows
return: "Success!" next: end
JSON des workflows
{ "return": "Success!", "next": "end" }
Task
Un état Task représente une seule unité de travail effectuée par une machine à états. Dans l'exemple Step Functions suivant, il appelle une fonction Lambda.
(Les activités sont une fonctionnalité AWS Step Functions qui vous permet d'avoir une tâche dans votre machine à états où le travail est effectué ailleurs.)
Dans l'exemple de Workflows, un appel est effectué à un point de terminaison HTTP pour appeler une fonction Cloud Run. Vous pouvez également utiliser un connecteur qui permet d'accéder facilement à d'autres produits Google Cloud. Vous pouvez également mettre en pause un workflow et interroger les données. Vous pouvez également utiliser un point de terminaison de rappel pour signaler à votre workflow qu'un événement spécifié s'est produit et attendre cet événement sans interrogation.
Fonctions en escalier
"HelloWorld": { "Type": "Task", "Resource": "arn:aws:lambda:us-east-1:123456789012:function:HelloFunction", "End": true }
Fichier YAML des workflows
- HelloWorld: call: http.get args: url: https://REGION-PROJECT_ID.cloudfunctions.net/helloworld result: helloworld_result
JSON des workflows
[ { "HelloWorld": { "call": "http.get", "args": { "url": "https://REGION-PROJECT_ID.cloudfunctions.net/helloworld" }, "result": "helloworld_result" } } ]
Wait
Un état Wait empêche la machine d'état de continuer pendant une durée spécifiée.
Vous pouvez utiliser la fonction de bibliothèque standard sys.sleep de Workflows pour suspendre l'exécution du nombre de secondes spécifié à un maximum de 3 153 6000 (un an).
Fonctions en escalier
"wait_ten_seconds" : { "Type" : "Wait", "Seconds" : 10, "Next": "NextState" }
Fichier YAML des workflows
- someSleep: call: sys.sleep args: seconds: 10
JSON des workflows
[ { "someSleep": { "call": "sys.sleep", "args": { "seconds": 10 } } } ]
Exemple: Orchestration de microservices
L'exemple Step Functions suivant vérifie le prix d'une action, détermine s'il faut acheter ou vendre, puis indique le résultat. La machine à états de l'exemple s'intègre à AWS Lambda en transmettant des paramètres, utilise une file d'attente Amazon SQS pour demander une approbation humaine et utilise un sujet Amazon SNS pour renvoyer les résultats de la requête.
{
"StartAt": "Check Stock Price",
"Comment": "An example of integrating Lambda functions in Step Functions state machine",
"States": {
"Check Stock Price": {
"Type": "Task",
"Resource": "CHECK_STOCK_PRICE_LAMBDA_ARN",
"Next": "Generate Buy/Sell recommendation"
},
"Generate Buy/Sell recommendation": {
"Type": "Task",
"Resource": "GENERATE_BUY_SELL_RECOMMENDATION_LAMBDA_ARN",
"ResultPath": "$.recommended_type",
"Next": "Request Human Approval"
},
"Request Human Approval": {
"Type": "Task",
"Resource": "arn:PARTITION:states:::sqs:sendMessage.waitForTaskToken",
"Parameters": {
"QueueUrl": "REQUEST_HUMAN_APPROVAL_SQS_URL",
"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": "BUY_STOCK_LAMBDA_ARN",
"Next": "Report Result"
},
"Sell Stock": {
"Type": "Task",
"Resource": "SELL_STOCK_LAMBDA_ARN",
"Next": "Report Result"
},
"Report Result": {
"Type": "Task",
"Resource": "arn:PARTITION:states:::sns:publish",
"Parameters": {
"TopicArn": "REPORT_RESULT_SNS_TOPIC_ARN",
"Message": {
"Input.$": "$"
}
},
"End": true
}
}
}
Migrer vers Workflows
Pour migrer l'exemple Step Functions précédent vers Workflows, vous pouvez créer les étapes Workflows équivalentes en intégrant des fonctions Cloud Run, en prenant en charge un point de terminaison de rappel qui attend que les requêtes HTTP arrivent à ce point de terminaison, et en utilisant un connecteur Workflows pour publier sur un sujet Pub/Sub à la place du sujet Amazon SNS:
Suivez la procédure pour créer un workflow, mais ne le déployez pas encore.
Dans la définition du workflow, ajoutez une étape permettant de créer un point de terminaison de rappel qui attend une entrée humaine et une étape qui utilise un connecteur Workflows pour publier sur un sujet Pub/Sub. Exemple :
Fichier YAML des workflows
--- main: steps: - init: assign: - projectId: '${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}' - region: LOCATION - topic: PUBSUB_TOPIC_NAME - Check Stock Price: call: http.get args: url: ${"https://" + region + "-" + projectId + ".cloudfunctions.net/CheckStockPrice"} auth: type: OIDC result: stockPriceResponse - Generate Buy/Sell Recommendation: call: http.get args: url: ${"https://" + region + "-" + projectId + ".cloudfunctions.net/BuySellRecommend"} auth: type: OIDC query: price: ${stockPriceResponse.body.stock_price} result: recommendResponse - Create Approval Callback: call: events.create_callback_endpoint args: http_callback_method: "GET" result: callback_details - Print Approval Callback Details: call: sys.log args: severity: "INFO" text: ${"Listening for callbacks on " + callback_details.url} - Await Approval Callback: call: events.await_callback args: callback: ${callback_details} timeout: 3600 result: approvalResponse - Approval?: try: switch: - condition: ${approvalResponse.http_request.query.response[0] == "yes"} next: Buy or Sell? except: as: e steps: - unknown_response: raise: ${"Unknown response:" + e.message} next: end - Buy or Sell?: switch: - condition: ${recommendResponse.body == "buy"} next: Buy Stock - condition: ${recommendResponse.body == "sell"} next: Sell Stock - condition: true raise: ${"Unknown recommendation:" + recommendResponse.body} - Buy Stock: call: http.post args: url: ${"https://" + region + "-" + projectId + ".cloudfunctions.net/BuyStock"} auth: type: OIDC body: action: ${recommendResponse.body} result: message - Sell Stock: call: http.post args: url: ${"https://" + region + "-" + projectId + ".cloudfunctions.net/SellStock"} auth: type: OIDC body: action: ${recommendResponse.body} result: message - Report Result: call: googleapis.pubsub.v1.projects.topics.publish args: topic: ${"projects/" + projectId + "/topics/" + topic} body: messages: - data: '${base64.encode(json.encode(message))}' next: end ...
JSON des workflows
{ "main": { "steps": [ { "init": { "assign": [ { "projectId": "${sys.get_env(\"GOOGLE_CLOUD_PROJECT_ID\")}" }, { "region": "LOCATION" }, { "topic": [ "PUBSUB_TOPIC_NAME" ] } ] } }, { "Check Stock Price": { "call": "http.get", "args": { "url": "${\"https://\" + region + \"-\" + projectId + \".cloudfunctions.net/CheckStockPrice\"}", "auth": { "type": "OIDC" } }, "result": "stockPriceResponse" } }, { "Generate Buy/Sell Recommendation": { "call": "http.get", "args": { "url": "${\"https://\" + region + \"-\" + projectId + \".cloudfunctions.net/BuySellRecommend\"}", "auth": { "type": "OIDC" }, "query": { "price": "${stockPriceResponse.body.stock_price}" } }, "result": "recommendResponse" } }, { "Create Approval Callback": { "call": "events.create_callback_endpoint", "args": { "http_callback_method": "GET" }, "result": "callback_details" } }, { "Print Approval Callback Details": { "call": "sys.log", "args": { "severity": "INFO", "text": "${\"Listening for callbacks on \" + callback_details.url}" } } }, { "Await Approval Callback": { "call": "events.await_callback", "args": { "callback": "${callback_details}", "timeout": 3600 }, "result": "approvalResponse" } }, { "Approval?": { "try": { "switch": [ { "condition": "${approvalResponse.http_request.query.response[0] == \"yes\"}", "next": "Buy or Sell?" } ] }, "except": { "as": "e", "steps": [ { "unknown_response": { "raise": "${\"Unknown response:\" + e.message}", "next": "end" } } ] } } }, { "Buy or Sell?": { "switch": [ { "condition": "${recommendResponse.body == \"buy\"}", "next": "Buy Stock" }, { "condition": "${recommendResponse.body == \"sell\"}", "next": "Sell Stock" }, { "condition": true, "raise": "${\"Unknown recommendation:\" + recommendResponse.body}" } ] } }, { "Buy Stock": { "call": "http.post", "args": { "url": "${\"https://\" + region + \"-\" + projectId + \".cloudfunctions.net/BuyStock\"}", "auth": { "type": "OIDC" }, "body": { "action": "${recommendResponse.body}" } }, "result": "message" } }, { "Sell Stock": { "call": "http.post", "args": { "url": "${\"https://\" + region + \"-\" + projectId + \".cloudfunctions.net/SellStock\"}", "auth": { "type": "OIDC" }, "body": { "action": "${recommendResponse.body}" } }, "result": "message" } }, { "Report Result": { "call": "googleapis.pubsub.v1.projects.topics.publish", "args": { "topic": "${\"projects/\" + projectId + \"/topics/\" + topic}", "body": { "messages": [ { "data": "${base64.encode(json.encode(message))}" } ] } }, "next": "end" } } ] } }
Remplacez les éléments suivants :
LOCATION: région Google Cloud compatible. Par exemple,us-central1.PUBSUB_TOPIC_NAME: nom de votre sujet Pub/Sub. Exemple :my_stock_example
Déployez, puis exécutez le workflow.
Pendant l'exécution du workflow, il se met en pause et attend que vous appeliez le point de terminaison de rappel. Pour ce faire, vous pouvez utiliser une commande curl. Exemple :
curl -H "Authorization: Bearer $(gcloud auth print-access-token)" https://workflowexecutions.googleapis.com/v1/projects/CALLBACK_URL?response=yesRemplacez
CALLBACK_URLpar le reste du chemin d'accès à votre point de terminaison de rappel.Une fois le workflow terminé, vous pouvez recevoir le message de l'abonnement Pub/Sub. Exemple :
gcloud pubsub subscriptions pull stock_example-sub --format="value(message.data)" | jqLe message de sortie doit ressembler à ce qui suit (
buyousell):{ "body": "buy", "code": 200, "headers": { [...] }
Étape suivante
- Présentation des workflows
- Créer et gérer des workflows
- Exemples de workflows
- Documentation de référence sur la syntaxe des workflows