我想实现的任务是:我想创建工作流,向工作流添加作业和触发器,并运行工作流
我使用下面的代码来创建工作流
import boto3
def create_workflow(wf_name):
response = client.create_workflow(
Name=wf_name,
Description='string'
)
return response['Name']
wf_name=create_workflow('wf_dev_jan_5th')
下面的代码我已经用来添加作业和触发器到现有的工作流
response_trigger=client.create_trigger(
Name="new_trigger",
WorkflowName="wf_dev_jan_5th",Type='ON_DEMAND',Actions=[
{
'JobName': 'abc_dev",
'Arguments': {
'string': 'string'
},
'Timeout': 123,
'SecurityConfiguration': 'string',
'NotificationProperty': {
'NotifyDelayAfter': 123
}
},
])
从上面的代码中,我可以看到使用name创建的工作流。我有两个工作一个与'abc_dev'和'def_dev'
当我在工作流wf_dev_jan_5th上使用new_trigger创建触发器名称时,它没有抛出任何错误
但是当我用new_trigger_1与不同的工作创建触发器名称时,即在相同的工作流wf_dev_jan_5th上创建def_dev,它会抛出以下错误
error:IdempotentParameterMismatchException: An error occurred (IdempotentParameterMismatchException) when calling the CreateTrigger operation: Trigger with name 'new_trigger' already submitted with different configuration
有人能帮帮忙吗
我找到了一个使用boto3 create_trigger()的解决方案,我们可以在其中添加触发器和作业到工作流