Trigger - AWS Glue
 - tipi di dati -TriggerTriggerUpdatePredicateCondizioneAzioneEventBatchingCondition - operazioni -CreateTrigger (create_trigger)StartTrigger (start_trigger)GetTrigger (get_trigger)GetTriggers (get_triggers)UpdateTrigger (update_trigger)StopTrigger (stop_trigger)DeleteTrigger (delete_trigger)ListTriggers (list_triggers)BatchGetTriggers (batch_get_triggers)

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Trigger

L'API Triggers descrive i tipi di dati e l'API relativa alla creazione, all'aggiornamento o all'eliminazione e l'avvio e l'arresto di attivatori di processi in AWS Glue.

Tipi di dati

Struttura trigger

Informazioni su un trigger specifico.

Campi

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger.

  • WorkflowName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del flusso di lavoro associato al trigger.

  • Id: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Riservato per uso futuro.

  • Type: stringa UTF-8 (valori validi: SCHEDULED | CONDITIONAL | ON_DEMAND | EVENT).

    Il tipo di trigger.

  • State: stringa UTF-8 (valori validi: CREATING | CREATED | ACTIVATING | ACTIVATED | DEACTIVATING | DEACTIVATED | DELETING | UPDATING).

    Lo stato corrente del trigger.

  • Description: stringa di descrizione, non superiore a 2048 byte di lunghezza, corrispondente a URI address multi-line string pattern.

    Una descrizione di questo trigger.

  • Schedule: stringa UTF-8.

    Espressione cron usata per specificare la pianificazione (consulta Pianificazioni basate sul tempo per processi e crawler. Ad esempio, per eseguire un processo ogni giorno alle 12:15 UTC, devi specificare: cron(15 12 * * ? *).

  • Actions: una matrice di oggetti Azione.

    Le operazioni avviate da questo trigger.

  • Predicate: un oggetto Predicate.

    Il predicato di questo trigger, che definisce quando verrà attivato.

  • EventBatchingCondition: un oggetto EventBatchingCondition.

    Condizione Batch che deve essere soddisfatta (numero specificato di eventi ricevuti o finestra di tempo batch scaduta) prima che si attivi il trigger di eventi EventBridge.

Struttura TriggerUpdate

Una struttura utilizzata per fornire informazioni per l'aggiornamento di un trigger. Questo oggetto aggiorna la definizione trigger precedente sovrascrivendola completamente.

Campi

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Riservato per uso futuro.

  • Description: stringa di descrizione, non superiore a 2048 byte di lunghezza, corrispondente a URI address multi-line string pattern.

    Una descrizione di questo trigger.

  • Schedule: stringa UTF-8.

    Espressione cron usata per specificare la pianificazione (consulta Pianificazioni basate sul tempo per processi e crawler. Ad esempio, per eseguire un processo ogni giorno alle 12:15 UTC, devi specificare: cron(15 12 * * ? *).

  • Actions: una matrice di oggetti Azione.

    Le operazioni avviate da questo trigger.

  • Predicate: un oggetto Predicate.

    Il predicato di questo trigger, che definisce quando verrà attivato.

  • EventBatchingCondition: un oggetto EventBatchingCondition.

    Condizione Batch che deve essere soddisfatta (numero specificato di eventi ricevuti o finestra di tempo batch scaduta) prima che si attivi il trigger di eventi EventBridge.

Struttura predicato

Definisce il predicato del trigger, che determina il momento in cui viene attivato.

Campi

  • Logical: stringa UTF-8 (valori validi: AND | ANY).

    Campo opzionale se è elencata una sola condizione. Se sono elencate più condizioni, questo campo è obbligatorio.

  • Conditions: una matrice di oggetti Condizione, non superiore a 500 strutture.

    Un elenco delle condizioni che determinano il momento in cui il trigger verrà attivato.

Struttura condizione

Definisce una condizione nella quale un trigger si attiva.

Campi

  • LogicalOperator: stringa UTF-8 (valori validi: EQUALS).

    Un operatore logico.

  • JobName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del processo ali cui JobRuns si applica questa condizione e su cui attende questo trigger.

  • State: stringa UTF-8 (valori validi: STARTING | RUNNING | STOPPING | STOPPED | SUCCEEDED | FAILED | TIMEOUT | ERROR | WAITING | EXPIRED).

    Lo stato della condizione. Attualmente, gli unici processi che stabiliscono che un trigger può essere ascoltato sono SUCCEEDED, STOPPED, FAILED e TIMEOUT. Gli unici crawler che stabiliscono che un trigger può ascoltare sono SUCCEEDED, FAILED e CANCELLED.

  • CrawlerName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del crawler a cui si applica questa condizione.

  • CrawlState: stringa UTF-8 (valori validi: RUNNING | CANCELLING | CANCELLED | SUCCEEDED | FAILED | ERROR).

    Lo stato del crawler a cui si applica questa condizione.

Struttura operazione

Definisce un'operazione che deve essere avviata da un trigger.

Campi

  • JobName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Nome del processo che viene eseguito.

  • Arguments: una matrice della mappa di coppie chiave-valore.

    Ogni chiave è una stringa UTF-8.

    Ogni valore è una stringa UTF-8.

    Gli argomenti del processo utilizzati quando viene attivato il trigger. Per questa esecuzione di processo, sostituiscono gli argomenti predefiniti impostati nella definizione del processo stessa.

    Qui puoi specificare gli argomenti utilizzati dal tuo script di esecuzione processo, nonché gli argomenti utilizzati da AWS Glue stesso.

    Per informazioni su come specificare e utilizzare gli argomenti del proprio processo, fai riferimento a Chiamare le API AWS Glue in Python nella guida per gli sviluppatori.

    Per informazioni sulle coppie chiave-valore che AWS Glue utilizza per configurare il processo, fai riferimento a Parametri speciali utilizzati da AWS Glue contenuto nella guida per gli sviluppatori.

  • Timeout: numero (intero), almeno 1.

    Timeout di JobRun (in minuti). Indica il tempo massimo durante cui l'esecuzione di un processo può utilizzare le risorse prima di essere terminata e passare allo stato TIMEOUT. Questo valore sostituisce il valore di timeout impostato nel processo padre.

    I processi devono avere valori di timeout inferiori a 7 giorni o 10.080 minuti. In caso contrario, i processi genereranno un'eccezione.

    Quando il valore viene lasciato vuoto, il timeout viene impostato sul valore predefinito di 2.880 minuti.

    Tutti i processi AWS Glue esistenti con un valore di timeout superiore a 7 giorni verranno impostati sul valore predefinito di 7 giorni. Ad esempio, se un processo in batch ha impostato un timeout di 20 giorni, sarà interrotto al settimo giorno.

    Per i processi di streaming, se è stata impostata una finestra di manutenzione, il processo sarà riavviato durante tale finestra dopo 7 giorni.

  • SecurityConfiguration: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Nome della struttura SecurityConfiguration da usare con questa operazione.

  • NotificationProperty: un oggetto NotificationProperty.

    Specifica le proprietà di configurazione di una notifica di esecuzione di un processo.

  • CrawlerName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del crawler da usare con questa operazione.

Struttura EventBatchingCondition

Condizione Batch che deve essere soddisfatta (numero specificato di eventi ricevuti o finestra di tempo batch scaduta) prima che si attivi il trigger di eventi EventBridge.

Campi

  • BatchSize - obbligatorio: numero (intero), non inferiore a 1 o superiore a 100.

    Numero di eventi che devono essere ricevuti da Amazon EventBridge prima che si attivi il trigger di eventi EventBridge.

  • BatchWindow: numero (intero), non inferiore a 1 o superiore a 900.

    Finestra di tempo espressa in secondi dopo la quale si attiva il trigger di eventi EventBridge. La finestra inizia quando viene ricevuto il primo evento.

Operazioni

Operazione CreateTrigger (Python: create_trigger)

Crea un nuovo trigger.

Gli argomenti del processo potrebbero essere registrati. Non passare segreti in testo chiaro come argomenti. Recuperare segreti da una connessione AWS Glue, da AWS Secrets Manager o da un altro meccanismo di gestione segreta se si intende mantenerli all'interno del processo.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger.

  • WorkflowName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del flusso di lavoro associato al trigger.

  • Type - obbligatorio: stringa UTF-8 (valori validi: SCHEDULED | CONDITIONAL | ON_DEMAND | EVENT).

    Il tipo del nuovo trigger.

  • Schedule: stringa UTF-8.

    Espressione cron usata per specificare la pianificazione (consulta Pianificazioni basate sul tempo per processi e crawler. Ad esempio, per eseguire un processo ogni giorno alle 12:15 UTC, devi specificare: cron(15 12 * * ? *).

    Questo campo è obbligatorio quando il tipo di trigger è SCHEDULED (PIANIFICATO).

  • Predicate: un oggetto Predicate.

    Un predicato per specificare quando occorre attivare il nuovo trigger.

    Questo campo è obbligatorio quando il tipo di trigger è CONDITIONAL.

  • Actions - obbligatorio: una matrice di oggetti Azione.

    Le operazioni avviate da questo trigger al momento dell'attivazione.

  • Description: stringa di descrizione, non superiore a 2048 byte di lunghezza, corrispondente a URI address multi-line string pattern.

    Una descrizione del nuovo trigger.

  • StartOnCreation: booleano.

    Imposta su true per avviare i trigger SCHEDULED e CONDITIONAL al momento della creazione. True non è supportato per i trigger ON_DEMAND.

  • Tags: una matrice di mappe con coppie chiave-valore, non superiore alle 50 coppie.

    Ogni chiave è una stringa UTF-8, non inferiore a 1 o superiore a 128 byte di lunghezza.

    Ogni valore è una stringa UTF-8, lunga non più di 256 byte.

    I tag da usare con questo trigger. Puoi usare i tag per limitare l'accesso al trigger. Per ulteriori informazioni sui tag in AWS Glue, consulta Tag AWS in AWS Glue nella guida per gli sviluppatori.

  • EventBatchingCondition: un oggetto EventBatchingCondition.

    Condizione Batch che deve essere soddisfatta (numero specificato di eventi ricevuti o finestra di tempo batch scaduta) prima che si attivi il trigger di eventi EventBridge.

Risposta

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger.

Errori

  • AlreadyExistsException

  • EntityNotFoundException

  • InvalidInputException

  • IdempotentParameterMismatchException

  • InternalServiceException

  • OperationTimeoutException

  • ResourceNumberLimitExceededException

  • ConcurrentModificationException

Operazione StartTrigger (Python: start_trigger)

Avvia un trigger esistente. Consulta la sezione Avvio dei processi per informazioni sull'avvio dei diversi tipi di trigger.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger da avviare.

Risposta

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger avviato.

Errori

  • InvalidInputException

  • InternalServiceException

  • EntityNotFoundException

  • OperationTimeoutException

  • ResourceNumberLimitExceededException

  • ConcurrentRunsExceededException

Operazione GetTrigger (Python: get_trigger)

Recupera la definizione di un trigger.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Nome del trigger da recuperare.

Risposta

  • Trigger: un oggetto Trigger.

    La definizione del trigger richiesta.

Errori

  • EntityNotFoundException

  • InvalidInputException

  • InternalServiceException

  • OperationTimeoutException

Operazione GetTriggers (Python: get_triggers)

Ottiene tutti i trigger associati a un processo.

Richiesta

  • NextToken: stringa UTF-8.

    Un token di continuazione, se si tratta di una chiamata di continuazione.

  • DependentJobName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del processo per cui recuperare i trigger. Il trigger che può avviare questo processo viene restituito e, se non esiste nessun trigger di questo tipo, vengono restituiti tutti i trigger.

  • MaxResults: numero (intero), non inferiore a 1 o superiore a 200.

    La dimensione massima della risposta.

Risposta

  • Triggers: una matrice di oggetti Trigger.

    Un elenco di trigger per il processo specificato.

  • NextToken: stringa UTF-8.

    Un token di continuazione, se non sono ancora stati restituiti tutti i trigger richiesti.

Errori

  • EntityNotFoundException

  • InvalidInputException

  • InternalServiceException

  • OperationTimeoutException

Operazione UpdateTrigger (Python: update_trigger)

Aggiorna una definizione del trigger.

Gli argomenti del processo potrebbero essere registrati. Non passare segreti in testo chiaro come argomenti. Recuperare segreti da una connessione AWS Glue, da AWS Secrets Manager o da un altro meccanismo di gestione segreta se si intende mantenerli all'interno del processo.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger da aggiornare.

  • TriggerUpdate - obbligatorio: un oggetto TriggerUpdate.

    I nuovi valori con cui aggiornare il trigger.

Risposta

  • Trigger: un oggetto Trigger.

    La definizione del trigger risultante.

Errori

  • InvalidInputException

  • InternalServiceException

  • EntityNotFoundException

  • OperationTimeoutException

  • ConcurrentModificationException

Operazione StopTrigger (Python: stop_trigger)

Arresta un trigger specificato.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger da arrestare.

Risposta

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger che è stato arrestato.

Errori

  • InvalidInputException

  • InternalServiceException

  • EntityNotFoundException

  • OperationTimeoutException

  • ConcurrentModificationException

Operazione DeleteTrigger (Python: delete_trigger)

Elimina un trigger specificato. Se il trigger non viene trovato, non viene generata alcuna eccezione.

Richiesta

  • Name - obbligatorio: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger da eliminare.

Risposta

  • Name: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del trigger che è stato eliminato.

Errori

  • InvalidInputException

  • InternalServiceException

  • OperationTimeoutException

  • ConcurrentModificationException

Operazione ListTriggers (Python: list_triggers)

Recupera i nomi di tutte le risorse trigger in questo account AWS oppure le risorse con il tag specificato. Questa operazione consente di vedere quali risorse sono disponibili nel proprio account e i relativi nomi.

L'operazione accetta il campo facoltativo Tags che si può utilizzare come filtro per la risposta in modo che le risorse con tag possano essere recuperate come gruppo. Se si sceglie di utilizzare il filtro dei tag, potranno essere recuperate solo le risorse con tag.

Richiesta

  • NextToken: stringa UTF-8.

    Token di continuazione, se si tratta di una richiesta di continuazione.

  • DependentJobName: stringa UTF-8, non inferiore a 1 o superiore a 255 byte di lunghezza, corrispondente a Single-line string pattern.

    Il nome del processo per cui recuperare i trigger. Viene restituito il trigger che può avviare questo processo. Se non esiste un trigger di questo tipo, vengono restituiti tutti i trigger.

  • MaxResults: numero (intero), non inferiore a 1 o superiore a 200.

    La dimensione massima di un elenco da restituire.

  • Tags: una matrice di mappe con coppie chiave-valore, non superiore alle 50 coppie.

    Ogni chiave è una stringa UTF-8, non inferiore a 1 o superiore a 128 byte di lunghezza.

    Ogni valore è una stringa UTF-8, lunga non più di 256 byte.

    Specifica che vengono restituite solo le risorse con tag.

Risposta

  • TriggerNames: una matrice di stringhe UTF-8.

    I nomi di tutti i trigger nell'account oppure i trigger con i tag specificati.

  • NextToken: stringa UTF-8.

    Token di continuazione, se l'elenco restituito non contiene l'ultimo parametro disponibile.

Errori

  • EntityNotFoundException

  • InvalidInputException

  • InternalServiceException

  • OperationTimeoutException

Operazione BatchGetTriggers (Python: batch_get_triggers)

Restituisce un elenco di metadati di risorse per un determinato elenco di nomi di trigger. Dopo aver chiamato l'operazione ListTriggers, puoi chiamare questa operazione per accedere ai dati a cui sono state concesse le autorizzazioni. Questa operazione supporta tutte le autorizzazioni IAM, tra cui le condizioni di autorizzazione che utilizzano i tag.

Richiesta

  • TriggerNames - obbligatorio: matrice di stringhe UTF-8.

    L'elenco dei nomi di trigger che potrebbero essere i nomi restituiti dall'operazione ListTriggers.

Risposta

  • Triggers: una matrice di oggetti Trigger.

    Un elenco di definizioni di trigger.

  • TriggersNotFound: una matrice di stringhe UTF-8.

    Un elenco di nomi di trigger non trovati.

Errori

  • InternalServiceException

  • OperationTimeoutException

  • InvalidInputException