StepFunctions/Lambda 和云服务器

StepFunctions/Lambda and ECS

这是我尝试使用 StepFunctions/Lambda/ECS+Fargate+python+docker

进行的操作

我有一份工作正在排队请求并轮询以查看请求是否完成。完成后,需要下载请求文件。除下载文件外,上述所有步骤均使用 Lambda 和 Step 函数中的 Choices 完成。

问题:我需要做的是从“文件准备好了吗?”中发送 JobID。选择 Fargate/ECS 容器,以便容器中的 python 脚本下载文件并将其放入 S3。

这是正确的思考过程吗:不知何故在“文件准备好了吗?”说明输出应该包括 ECSTaskRun 可以使用的 json?这个 json 输出应该有 Job_id 作为 evn 参数?完成后,python 脚本可以读取 job_id 作为 env 参数,os.environ.get('job_id),并执行剩余的项目?

或者,我走错路了。

我也在 Python CDK 中部署所有内容。

感谢反馈。

您将参数传递给 SF 中的 ECS 任务,使用 Overrides 作为您的任务定义。如果您想将变量作为环境变量传递,则必须在 ContainerOverrides.

中覆盖 Environment