python - AWS Glue 通过 API 创建触发器

Question

我有一个表格，其中包含各种工作的一些时间表。

我想通过 AWS Glue API 处理记录并创建触发器。

http://docs.aws.amazon.com/glue/latest/dg/aws-glue-api.html

上面的链接显示了 AWS Glue 的文档。

是否有人可以提供有关如何使用 API 的代码片段？我在网上搜索了足够长的时间，但没有找到任何提供代码片段的文档!

我正在寻找以下 API 调用的代码片段。CreateTrigger 操作(Python:create_trigger)

任何帮助都会很棒。

Answer 1

这是关于如何创建基于计划的触发器的简要介绍。请注意触发器如何运行多个作业(软限制是每个触发器 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'
            ),
        ]
    )
)  

希望对你有帮助