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
这是我尝试使用 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