2017-12-26 12 views
0

다양한 작업에 대한 일정이 적은 표가 있습니다.AWS Glue create API를 통한 트리거

레코드를 처리하고 AWS Glue API를 통해 트리거를 생성하고 싶습니다.

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

위의 링크는 문서 AWS 접착제 갈 보여줍니다.

API 사용 방법에 대한 코드 스 니펫을 제공 할 수있는 사람이 있습니까? 인터넷에서 오랫동안 충분히 검색했으며 havent은 코드 스 니펫을 제공하는 문서를 찾았습니다!

다음 API CALL에 대한 코드 스 니펫을 찾고 있습니다. CreateTrigger 액션 (Python : create_trigger)

도움이 될 것입니다.

+0

[이 페이지] (http://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-jobs-trigger.html#aws-glue하는 데 도움이 -api-jobs-trigger-CreateTrigger) API 호출에 필요한 요청 매개 변수에 대한 설명을 제공합니다. – Marathon55

+0

http://docs.aws.amazon.com/glue/l atest/dg/aws-glue-programming-python-calling.html –

답변

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

희망이