2017-12-26 5 views
0

Ich habe eine Tabelle, die wenige Zeitpläne für verschiedene Jobs enthält.AWS Glue create Trigger über API

Ich möchte die Datensätze verarbeiten und Triggers über AWS Glue API erstellen.

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

Der obige Link zeigt die Dokumentation für AWS Kleber gehen.

Gibt es jemanden, der ein Code-Snippet zur Verwendung der API bereitstellen kann? Ich habe lange genug im Internet gesucht und habe keine Dokumentation gefunden, die ein Code-Snippet liefert!

Ich bin auf der Suche nach Code-Snippet für die folgende API CALL. CreateTrigger Aktion (Python: create_trigger)

Jede Hilfe wäre großartig.

+0

[diese Seite] (http://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-jobs-trigger.html#aws-glue -api-jobs-trigger-CreateTrigger) gibt die Beschreibungen der Anforderungsparameter an, die Sie in Ihrem API-Aufruf – Marathon55

+0

http://docs.aws.amazon.com/glue/l benötigen atest/dg/aws-kleber-programmierung-python-rufing.html –

Antwort

1

Dies ist ein kurzer Ausschnitt davon, wie man einen zeitplanbasierten Trigger erstellt. Beachten Sie, wie Sie mehrere Jobs (Soft-Limit ist 10 pro Trigger) lief durch den Auslöser haben:

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

Wenn Sie den Auslöser wollte laufen, um den Job, nachdem einige andere Jobs gelingt es Ihnen, den Auslöser wie folgt definieren würde:

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

hoffe, das hilft

Verwandte Themen