L'API Pulumi Automation n'exécute pas la CLI Pulumi ?

J'écris une application Flask qui utilise l'API Pulumi Automation. Je suis les exemples de projet Automation API. Mais lorsque j'envoie une requête POST, un programme s'exécute sans que le moteur Pulumi soit disponible. réexécutez en utilisant l' erreur Pulumi CLI. L'API d'automatisation n'est-elle pas censée exécuter la CLI toute seule ?

La CLI Pulumi est disponible:

Pulumi version v3.24.1

edit: j'ai suivi l'exemple pulumi over HTTP, voici mon app.py

import pulumi
from flask import Flask, request, make_response, jsonify
from pulumi import automation as auto
import os
from pulumi_aws import s3
app = Flask(__name__)
# This function defines our pulumi s3 static website in terms of the content that the caller passes in.
# This allows us to dynamically deploy websites based on user defined values from the POST body.
def create_pulumi_program(content: str):
 # Create a bucket and expose a website index document
 site_bucket = s3.Bucket("s3-website-bucket", website=s3.BucketWebsiteArgs(index_document="index.html"))
 index_content = content
 # Write our index.html into the site bucket
 s3.BucketObject("index",
  bucket=site_bucket.id,
  content=index_content,
  key="index.html",
  content_type="text/html; charset=utf-8")
 # Set the access policy for the bucket so all objects are readable
 s3.BucketPolicy("bucket-policy",
  bucket=site_bucket.id,
  policy={
  "Version": "2012-10-17",
  "Statement": {
  "Effect": "Allow",
  "Principal": "*",
  "Action": ["s3:GetObject"],
  # Policy refers to bucket explicitly
  "Resource": [pulumi.Output.concat("arn:aws:s3:::", site_bucket.id, "/*")]
  },
  })
 # Export the website URL
 pulumi.export("website_url", site_bucket.website_endpoint)
@app.route('/', methods=['GET'])
def home():
 return "<h1>Hello</p>"
@app.route('/v1/code', methods=['POST'])
def create_handler():
 content = request.get_json()
 project_name = content.get('project_name')
 stack_name = content.get('stack_name')
 pulumi_access_token = request.headers['pulumi_access_token']
 os.environ['PULUMI_ACCESS_TOKEN'] = pulumi_access_token
 try:
 def pulumi_program():
 return create_pulumi_program(content)
 stack = auto.create_stack(stack_name=stack_name,
   project_name=project_name,
   program=create_pulumi_program(content))
 stack.workspace.install_plugin("aws", "v4.0.0")
 stack.set_config("aws:region", auto.ConfigValue(value="us-west-2"))
 stack.set_config("aws:region", auto.ConfigValue("us-west-2"))
 # deploy the stack, tailing the logs to stdout
 up_res = stack.up(on_output=print)
 return jsonify(id=stack_name, url=up_res.outputs['website_url'].value)
 except auto.StackAlreadyExistsError:
 return make_response(f"stack '{stack_name}' already exists", 409)
 except Exception as exn:
 return make_response(str(exn), 500)
if __name__ == '__main__':
 app.run(debug=True)

Solution du problème

J'ai trouvé le problème, c'était parce que je passais un paramètre à la fonction du programme dans create_stack

stack = automation.create_stack(
 stack_name=stack_name, 
 project_name=project_name, 
 program=create_pulumi_program(content)
 )

Cela devrait plutôt être comme ceci:

stack = automation.create_stack(
 stack_name=stack_name, 
 project_name=project_name, 
 program=create_pulumi_program
)