

AWS Data Pipeline ist für Neukunden nicht mehr verfügbar. Bestandskunden von AWS Data Pipeline können den Service weiterhin wie gewohnt nutzen. [Weitere Informationen](https://aws.amazon.com/blogs/big-data/migrate-workloads-from-aws-data-pipeline/)

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

# Aktionen
<a name="dp-object-actions"></a>

Im Folgenden sind die AWS Data Pipeline Aktionsobjekte aufgeführt:

**Topics**
+ [SnsAlarm](dp-object-snsalarm.md)
+ [Beenden](dp-object-terminate.md)

# SnsAlarm
<a name="dp-object-snsalarm"></a>

 Sendet eine Amazon SNS SNS-Benachrichtigung, wenn eine Aktivität fehlschlägt oder erfolgreich abgeschlossen wird. 

## Beispiel
<a name="snsalarm-example"></a>

Es folgt ein Beispiel für diesen Objekttyp. Die Werte für `node.input` und `node.output` stammen vom Datenknoten oder der Aktivität, die im Feld `onSuccess` auf dieses Objekt verweist. 

```
{
  "id" : "SuccessNotify",
  "name" : "SuccessNotify",
  "type" : "SnsAlarm",
  "topicArn" : "arn:aws:sns:us-east-1:28619EXAMPLE:ExampleTopic",
  "subject" : "COPY SUCCESS: #{node.@scheduledStartTime}",
  "message" : "Files were copied from #{node.input} to #{node.output}."
}
```

## Syntax
<a name="snsalarm-syntax"></a>


****  

| Pflichtfelder | Description | Slot-Typ | 
| --- | --- | --- | 
| Nachricht | Der Textkörper der Amazon SNS-Benachrichtigung. | Zeichenfolge | 
| role | Die IAM-Rolle für die Erstellung des Amazon SNS-Alarms. | Zeichenfolge | 
| subject | Die Betreffzeile der Amazon SNS-Benachrichtigung. | Zeichenfolge | 
| topicArn | Der Amazon SNS-Thema-Ziel-ARN für die Nachricht. | Zeichenfolge | 

 


****  

| Optionale Felder | Description | Slot-Typ | 
| --- | --- | --- | 
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 | 

 


****  

| Laufzeitfelder | Description | Slot-Typ | 
| --- | --- | --- | 
| node | Der Knoten, für den diese Aktion ausgeführt wird. | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 | 
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge | 

 


****  

| Systemfelder | Description | Slot-Typ | 
| --- | --- | --- | 
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts. | Zeichenfolge | 
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört. | Zeichenfolge | 
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen. | Zeichenfolge | 

# Beenden
<a name="dp-object-terminate"></a>

Eine Aktion, die den Abbruch einer ausstehenden oder noch nicht abgeschlossenen Aktivität, Ressource oder eines Datenknotens auslöst. AWS Data Pipeline versucht, die Aktivität, die Ressource oder den Datenknoten in den Status CANCELLED zu versetzen, wenn nicht mit dem `lateAfterTimeout` Wert begonnen wird. 

Sie können keine Aktionen beenden, die `onSuccess`-, `OnFail`- oder `onLateAction`-Ressourcen beinhalten.

## Beispiel
<a name="terminate-example"></a>

Es folgt ein Beispiel für diesen Objekttyp. Bei diesem Beispiel enthält das Feld `onLateAction` `MyActivity` einen Verweis auf die Aktion `DefaultAction1`. Wenn Sie eine Aktion für `onLateAction` bereitstellen, müssen Sie auch einen `lateAfterTimeout`-Wert für den Zeitraum seit dem geplanten Start der Pipeline festlegen, nach dem die Aktivität als verspätet betrachtet wird.

```
{
  "name" : "MyActivity",
  "id" : "DefaultActivity1",
  "schedule" : {
    "ref" : "MySchedule"
  },
  "runsOn" : {
    "ref" : "MyEmrCluster"
  },
  "lateAfterTimeout" : "1 Hours",
  "type" : "EmrActivity",
  "onLateAction" : {
    "ref" : "DefaultAction1"
  },
  "step" : [
    "s3://amzn-s3-demo-bucket/myPath/myStep.jar,firstArg,secondArg",
    "s3://amzn-s3-demo-bucket/myPath/myOtherStep.jar,anotherArg"
  ]
},
{
  "name" : "TerminateTasks",
  "id" : "DefaultAction1",
  "type" : "Terminate"
}
```

## Syntax
<a name="terminate-syntax"></a>


****  

| Optionale Felder | Description | Slot-Typ | 
| --- | --- | --- | 
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, zum Beispiel „parent“: \$1"ref“:“ myBaseObject Id "\$1 | 

 


****  

| Laufzeitfelder | Description | Slot-Typ | 
| --- | --- | --- | 
| node | Der Knoten, für den diese Aktion ausgeführt wird. | Referenzobjekt, zum Beispiel „node“: \$1"ref“:“ myRunnableObject Id "\$1 | 
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde | Zeichenfolge | 

 


****  

| Systemfelder | Description | Slot-Typ | 
| --- | --- | --- | 
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts. | Zeichenfolge | 
| @pipelineId | ID der Pipeline, zu der dieses Objekt gehört. | Zeichenfolge | 
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen. | Zeichenfolge | 