AWS Glue 通过 API 创建触发器
AWS Glue create Triggers via API
我有一个 table,其中包含各种工作的一些时间表。
我想通过 AWS Glue API 处理记录并创建触发器。
http://docs.aws.amazon.com/glue/latest/dg/aws-glue-api.html
以上 link 显示了 AWS Glue 的文档。
是否有人可以提供有关如何使用 API 的代码片段?
我在网上搜索了足够长的时间,但没有找到任何提供代码片段的文档!
我正在寻找以下 API CALL 的代码片段。
创建触发器操作(Python:create_trigger)
任何帮助都会很棒。
http://boto3.readthedocs.io/en/latest/reference/services/glue.html#id75
这就是我要找的。
BOTO3 是用于调用 api 的库,并且具有相同的很好的文档
这是关于如何创建基于计划的触发器的简要介绍。请注意您如何拥有多个作业(每个触发器的软限制为 10 个)运行 触发器:
# Initialize glue client
import boto3
client = boto3.client('glue')
# Create trigger 'body'
trigger = dict(
Name='trigger_name',
Description='My trigger description',
Type='SCHEDULED',
Actions=[
dict(JobName='first_job_name_to_be_triggered'),
dict(JobName='second_job_name_to_be_triggered')
],
Schedule='cron(0 8 * * ? *)' #Every day at 8am UTC
)
# Create the trigger
client.create_trigger(**trigger)
# After trigger is created, you want to activate it
client.start_trigger(Name=trigger['Name'])
如果您希望触发器在其他一些作业成功后 运行 该作业,您可以这样定义触发器:
trigger = dict(
Name='trigger_name',
Description='My trigger description',
Type='CONDITIONAL',
Actions=[dict(JobName='job_name_to_be_triggered')],
Predicate=dict(
Logical='AND',
Conditions=[
dict(
JobName='first_job_required_to_succeed',
LogicalOperator='EQUALS',
State='SUCCEEDED'
),
dict(
JobName='second_job_required_to_succeed',
LogicalOperator='EQUALS',
State='SUCCEEDED'
),
]
)
)
希望对您有所帮助
我有一个 table,其中包含各种工作的一些时间表。
我想通过 AWS Glue API 处理记录并创建触发器。
http://docs.aws.amazon.com/glue/latest/dg/aws-glue-api.html
以上 link 显示了 AWS Glue 的文档。
是否有人可以提供有关如何使用 API 的代码片段? 我在网上搜索了足够长的时间,但没有找到任何提供代码片段的文档!
我正在寻找以下 API CALL 的代码片段。 创建触发器操作(Python:create_trigger)
任何帮助都会很棒。
http://boto3.readthedocs.io/en/latest/reference/services/glue.html#id75
这就是我要找的。 BOTO3 是用于调用 api 的库,并且具有相同的很好的文档
这是关于如何创建基于计划的触发器的简要介绍。请注意您如何拥有多个作业(每个触发器的软限制为 10 个)运行 触发器:
# Initialize glue client
import boto3
client = boto3.client('glue')
# Create trigger 'body'
trigger = dict(
Name='trigger_name',
Description='My trigger description',
Type='SCHEDULED',
Actions=[
dict(JobName='first_job_name_to_be_triggered'),
dict(JobName='second_job_name_to_be_triggered')
],
Schedule='cron(0 8 * * ? *)' #Every day at 8am UTC
)
# Create the trigger
client.create_trigger(**trigger)
# After trigger is created, you want to activate it
client.start_trigger(Name=trigger['Name'])
如果您希望触发器在其他一些作业成功后 运行 该作业,您可以这样定义触发器:
trigger = dict(
Name='trigger_name',
Description='My trigger description',
Type='CONDITIONAL',
Actions=[dict(JobName='job_name_to_be_triggered')],
Predicate=dict(
Logical='AND',
Conditions=[
dict(
JobName='first_job_required_to_succeed',
LogicalOperator='EQUALS',
State='SUCCEEDED'
),
dict(
JobName='second_job_required_to_succeed',
LogicalOperator='EQUALS',
State='SUCCEEDED'
),
]
)
)
希望对您有所帮助