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'
            ),
        ]
    )
)  

希望对您有所帮助