AWS Data Pipeline non è più disponibile per i nuovi clienti. I clienti esistenti di AWS Data Pipeline possono continuare a utilizzare il servizio normalmente. [Ulteriori informazioni](https://aws.amazon.com/blogs/big-data/migrate-workloads-from-aws-data-pipeline/)

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à.

# SqlActivity
<a name="dp-object-sqlactivity"></a>

Esegue una query SQL (script) su un database.

## Esempio
<a name="sqlactivity-example"></a>

Di seguito è illustrato un esempio di questo tipo di oggetto.

```
{
  "id" : "{{MySqlActivity}}",
  "type" : "SqlActivity",
  "database" : { "ref": "{{MyDatabaseID}}" },
  "script" : "{{SQLQuery}}" | "scriptUri" : {{s3://scriptBucket/query.sql}},
  "schedule" : { "ref": "{{MyScheduleID}}" },
}
```

## Sintassi
<a name="sqlactivity-syntax"></a>


****  

| Campi obbligatori | Description | Tipo di slot | 
| --- | --- | --- | 
| database | Il database su cui eseguire lo script SQL fornito. | Oggetto di riferimento, ad esempio «database»: {"ref»:» myDatabaseId «} | 

 


****  

| Campi Object Invocation | Description | Tipo di slot | 
| --- | --- | --- | 
| schedule | Questo oggetto viene richiamato entro l'esecuzione di un intervallo di pianificazione. È necessario specificare un riferimento alla pianificazione di un altro oggetto per impostare l'ordine di esecuzione delle dipendenze per questo oggetto. È possibile impostare una pianificazione esplicitamente sull'oggetto, ad esempio, specificando `"schedule": {"ref": "DefaultSchedule"}`. <br />Nella maggior parte dei casi, è meglio inserire il riferimento alla pianificazione nell'oggetto pipeline di default, in modo che tutti gli oggetti possano ereditare tale pianificazione. <br />Se la pipeline dispone di una struttura di pianificazioni nidificate all'interno della pianificazione principale, è possibile creare un oggetto padre che dispone di un riferimento alla pianificazione. Per ulteriori informazioni sulle configurazioni di pianificazione opzionali di esempio, consulta [https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html) | Oggetto di riferimento, ad esempio «schedule»: {"ref»:» myScheduleId «} | 

 


****  

| Gruppo richiesto (uno dei seguenti è obbligatorio) | Description | Tipo di slot | 
| --- | --- | --- | 
| script | Lo script SQL da eseguire. È necessario specificare lo script o lo scriptUri. Quando lo script viene archiviato in Amazon S3, lo script non viene valutato come espressione. Specificare più valori per ScriptArgument è utile quando lo script è archiviato in Amazon S3. | Stringa | 
| scriptUri | Un URI che specifica il percorso di uno script SQL da eseguire in questa attività. | Stringa | 

 


****  

| Gruppo richiesto (uno dei seguenti è obbligatorio) | Description | Tipo di slot | 
| --- | --- | --- | 
| runsOn | Le risorse di calcolo per eseguire l'attività o il comando. Ad esempio, un'istanza Amazon EC2 o un cluster Amazon EMR. | Oggetto di riferimento, ad esempio «runSon»: {"ref»:» myResourceId «} | 
| workerGroup | Il gruppo di lavoro. Utilizzato per le attività di routing. Se si fornisce un valore runsOn ed esiste workerGroup, workerGroup verrà ignorato. | Stringa | 

 


****  

| Campi opzionali | Description | Tipo di slot | 
| --- | --- | --- | 
| attemptStatus | Lo stato segnalato più di recente dall'attività remota. | Stringa | 
| attemptTimeout | Timeout per il completamento del lavoro in remoto. Se questo campo è impostato, un'attività remota che non viene completata entro il tempo impostato di avvio viene tentata di nuovo. | Periodo | 
| dependsOn | Specifica una dipendenza su un altro oggetto eseguibile. | Oggetto di riferimento, ad esempio «dependsOn»: {"ref»:» «myActivityId} | 
| failureAndRerunModalità | Descrive il comportamento del nodo consumer quando le dipendenze presentano un errore o vengono di nuovo eseguite | Enumerazione | 
| input | Posizione dei dati di input. | Oggetto di riferimento, ad esempio «input»: {"ref»:» myDataNode Id "} | 
| lateAfterTimeout | Il periodo di tempo dall'inizio programmato della pipeline all'interno del quale deve essere avviata l'esecuzione dell'oggetto. | Periodo | 
| maxActiveInstances | Il numero massimo di istanze attive simultanee di un componente. Le riesecuzioni non contano ai fini del numero di istanze attive. | Numero intero | 
| maximumRetries | Numero massimo di tentativi in caso di errore | Numero intero | 
| onFail | Un'azione da eseguire quando l'oggetto corrente ha esito negativo. | Oggetto di riferimento, ad esempio «onFail»: {"ref»:» myActionId «} | 
| onLateAction | Azioni che devono essere attivate se un oggetto non è ancora stato pianificato o non è ancora stato completato nel periodo di tempo trascorso dall'inizio programmato della pipeline, come specificato da ''. lateAfterTimeout | Oggetto di riferimento, ad esempio "onLateAction«: {" ref»:» myActionId «} | 
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: {"ref»:» myActionId «} | 
| output | Posizione dei dati di output. Questo è utile solo per fare riferimento dall'interno di uno script (ad esempio\#{output.tablename}) e per creare la tabella di output impostando 'createTableSql' nel nodo dati di output. L'output della query SQL non è scritto nel nodo dei dati di output. | Oggetto di riferimento, ad esempio «output»: {"ref»:» myDataNode Id "} | 
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: {"ref»:» myBaseObject Id "} | 
| pipelineLogUri | L'URI S3 (come 's3://BucketName/Key/ ') per caricare i log per la pipeline. | Stringa | 
| precondizione | Definisce eventualmente una precondizione. Un nodo dati non è contrassegnato come "READY" finché tutte le precondizioni non siano state soddisfatte. | Oggetto di riferimento, ad esempio «precondition»: {"ref»:» «} myPreconditionId | 
| coda | [solo Amazon Redshift] Corrisponde all'impostazione query\_group in Amazon Redshift che consente di assegnare e stabilire le priorità di attività simultanee in base al loro posizionamento nelle code. Amazon Redshift limita il numero di connessioni simultanee a 15. Per ulteriori informazioni, consulta [Assegnazione di query alle code](https://docs.aws.amazon.com/redshift/latest/dg/cm-c-executing-queries.html) nella Guida per gli sviluppatori di database Amazon Redshift. | Stringa | 
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. Se impostato, le attività in remoto che non presentano avanzamenti nel periodo specificato potrebbero essere considerate bloccate e sono quindi oggetto di un altro tentativo. | Periodo | 
| retryDelay | La durata del timeout tra due tentativi. | Periodo | 
| scheduleType | Il tipo di pianificazione consente di specificare se gli oggetti nella definizione di pipeline devono essere programmati all'inizio o alla fine dell'intervallo. I valori sono `cron`, `ondemand` e `timeseries`.<br /> La pianificazione `timeseries` significa che le istanze sono programmate al termine di ogni intervallo.<br />La pianificazione `cron` significa che le istanze sono programmate all'inizio di ogni intervallo. <br />Una pianificazione `ondemand`consente di eseguire una pipeline una sola volta, per attivazione. Questo significa che non è necessario clonare o ricreare la pipeline per eseguirla di nuovo. Se utilizzi una pianificazione `ondemand`, devi specificarlo nell'oggetto predefinito e deve essere l'unico `scheduleType` specificato per gli oggetti della pipeline. Per utilizzare le pipeline `ondemand`, chiama l'operazione `ActivatePipeline` per ogni esecuzione successiva. | Enumerazione | 
| scriptArgument | Un elenco di variabili per lo script. In alternativa, è possibile inserire le espressioni direttamente nel campo dello script. Per scriptArgument sono utili più valori quando lo script viene memorizzato in Amazon S3. Esempio: \# {format (@scheduledStartTime, "YY-MM-DD HH:MM:SS"}\\n\# {format (PlusPeriod (@scheduledStartTime, «1 day»), "HH:MM:SS"} YY-MM-DD  | Stringa | 

 


****  

| Campi Runtime | Description | Tipo di slot | 
| --- | --- | --- | 
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: {"ref»:» Id "} myRunnableObject | 
| @actualEndTime | L'ora in cui è terminata l'esecuzione di questo oggetto. | DateTime | 
| @actualStartTime | L'ora in cui è stata avviata l'esecuzione di questo oggetto. | DateTime | 
| cancellationReason | CancellationReason se questo oggetto è stato annullato. | Stringa | 
| @cascadeFailedOn | Descrizione della catena di dipendenza che ha generato l'errore dell'oggetto. | Oggetto di riferimento, ad esempio "cascadeFailedOn«: {" ref»:» myRunnableObject Id "} | 
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa | 
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa | 
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa | 
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa | 
| @finishedTime | L'ora in cui è terminata l'esecuzione di questo oggetto. | DateTime | 
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | Stringa | 
| @healthStatus | Lo stato di integrità dell'oggetto che riflette l'esito positivo o negativo dell'ultima istanza dell'oggetto che ha raggiunto lo stato di un'istanza terminata. | Stringa | 
| @healthStatusFromInstanceId | Id dell'ultimo oggetto dell'istanza che ha raggiunto lo stato terminato. | Stringa | 
| @ healthStatusUpdated Ora | L'ora in cui lo stato di integrità è stato aggiornato l'ultima volta. | DateTime | 
| hostname | Il nome host del client che si è aggiudicato il tentativo dell'attività. | Stringa | 
| @lastDeactivatedTime | L'ora in cui l'oggetto è stato disattivato. | DateTime | 
| @ latestCompletedRun Ora | L'orario dell'esecuzione più recente durante il quale l'esecuzione è stata completata. | DateTime | 
| @latestRunTime | L'orario dell'esecuzione più recente durante il quale l'esecuzione è stata pianificata. | DateTime | 
| @nextRunTime | L'orario dell'esecuzione da programmare come successiva. | DateTime | 
| reportProgressTime | Il periodo di tempo più recente in cui l'attività remota ha segnalato un progresso. | DateTime | 
| @scheduledEndTime | L'orario di termine della pianificazione per un oggetto | DateTime | 
| @scheduledStartTime | L'orario di inizio della pianificazione per l'oggetto | DateTime | 
| @status | Lo stato di questo oggetto. | Stringa | 
| @version | Versione della pipeline con cui l'oggetto è stato creato. | Stringa | 
| @waitingOn | Descrizione dell'elenco di dipendenze per cui questo oggetto è in attesa. | Oggetto di riferimento, ad esempio «waitingOn»: {"ref»:» myRunnableObject Id "} | 

 


****  

| Campi di sistema | Description | Tipo di slot | 
| --- | --- | --- | 
| @error | Errore che descrive il formato oggetto errato. | Stringa | 
| @pipelineId | L'id della pipeline a cui appartiene questo oggetto. | Stringa | 
| @sphere | La sfera di un oggetto indica la propria posizione nel ciclo di vita: i Component Objects generano Instance Objects che eseguono Attempt Objects. | Stringa |