2

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

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

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

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

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

我正在寻找以下 API CALL 的代码片段。 CreateTrigger 动作（Python：create_trigger）

任何帮助都会很棒。

4

2 回答 2

3

这是关于如何创建基于计划的触发器的快速剪辑。请注意触发器如何运行多个作业（软限制为每个触发器 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'
            ),
        ]
    )
)

希望这可以帮助

于 2018-01-01T00:17:10.037 回答
0

http://boto3.readthedocs.io/en/latest/reference/services/glue.html#id75

这就是我一直在寻找的。BOTO3 是用于调用 api 的库，并且有很好的文档

于 2017-12-26T19:48:14.053 回答