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.
# AWS Data Pipeline Beispiele mit AWS CLI
Die folgenden Codebeispiele zeigen Ihnen, wie Sie mithilfe von AWS Command Line Interface with Aktionen ausführen und allgemeine Szenarien implementieren AWS Data Pipeline.
*Aktionen* sind Codeauszüge aus größeren Programmen und müssen im Kontext ausgeführt werden. Während Aktionen Ihnen zeigen, wie Sie einzelne Service-Funktionen aufrufen, können Sie Aktionen im Kontext der zugehörigen Szenarien anzeigen.
Jedes Beispiel enthält einen Link zum vollständigen Quellcode, wo Sie Anweisungen zum Einrichten und Ausführen des Codes im Kodex finden.
**Topics**
+ [Aktionen](#actions)
## Aktionen
### `activate-pipeline`
Das folgende Codebeispiel zeigt, wie Sie`activate-pipeline`.
**AWS CLI**
**Um eine Pipeline zu aktivieren**
In diesem Beispiel wird die angegebene Pipeline aktiviert:
```
aws datapipeline activate-pipeline --pipeline-id df-00627471SOVYZEXAMPLE
```
Verwenden Sie den folgenden Befehl, um die Pipeline an einem bestimmten Zeitpunkt zu aktivieren:
```
aws datapipeline activate-pipeline --pipeline-id df-00627471SOVYZEXAMPLE --start-timestamp 2015-04-07T00:00:00Z
```
+ Einzelheiten zur API finden Sie [ActivatePipeline](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/activate-pipeline.html)in der *AWS CLI Befehlsreferenz*.
### `add-tags`
Das folgende Codebeispiel zeigt die Verwendung`add-tags`.
**AWS CLI**
**So fügen Sie einer Pipeline ein Tag hinzu**
In diesem Beispiel wird der angegebenen Pipeline das spezifizierte Tag hinzugefügt:
```
aws datapipeline add-tags --pipeline-id df-00627471SOVYZEXAMPLE --tags key=environment,value=production key=owner,value=sales
```
Verwenden Sie den Befehl describe-pipelines, um die Tags anzuzeigen. Die im Beispielbefehl hinzugefügten Tags werden in der Ausgabe für describe-pipelines wie folgt angezeigt:
```
{
...
"tags": [
{
"value": "production",
"key": "environment"
},
{
"value": "sales",
"key": "owner"
}
]
...
}
```
+ Einzelheiten zur API finden Sie [AddTags](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/add-tags.html)in der *AWS CLI Befehlsreferenz*.
### `create-pipeline`
Das folgende Codebeispiel zeigt die Verwendung`create-pipeline`.
**AWS CLI**
**Um eine Pipeline zu erstellen**
In diesem Beispiel wird eine Pipeline erstellt:
```
aws datapipeline create-pipeline --name my-pipeline --unique-id my-pipeline-token
```
Das Folgende ist eine Beispielausgabe:
```
{
"pipelineId": "df-00627471SOVYZEXAMPLE"
}
```
+ Einzelheiten zur API finden Sie [CreatePipeline](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/create-pipeline.html)in der *AWS CLI Befehlsreferenz*.
### `deactivate-pipeline`
Das folgende Codebeispiel zeigt die Verwendung`deactivate-pipeline`.
**AWS CLI**
**Um eine Pipeline zu deaktivieren**
In diesem Beispiel wird die angegebene Pipeline deaktiviert:
```
aws datapipeline deactivate-pipeline --pipeline-id df-00627471SOVYZEXAMPLE
```
Verwenden Sie den folgenden Befehl, um die Pipeline erst nach der Ausführung aller Aktivitäten zu deaktivieren:
```
aws datapipeline deactivate-pipeline --pipeline-id df-00627471SOVYZEXAMPLE --no-cancel-active
```
+ Einzelheiten zur API finden Sie [DeactivatePipeline](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/deactivate-pipeline.html)in der *AWS CLI Befehlsreferenz*.
### `delete-pipeline`
Das folgende Codebeispiel zeigt die Verwendung`delete-pipeline`.
**AWS CLI**
**Um eine Pipeline zu löschen**
In diesem Beispiel wird die angegebene Pipeline gelöscht:
```
aws datapipeline delete-pipeline --pipeline-id df-00627471SOVYZEXAMPLE
```
+ Einzelheiten zur API finden Sie [DeletePipeline](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/delete-pipeline.html)in der *AWS CLI Befehlsreferenz*.
### `describe-pipelines`
Das folgende Codebeispiel zeigt die Verwendung`describe-pipelines`.
**AWS CLI**
**So beschreiben Sie Ihre Pipelines**
In diesem Beispiel wird die angegebene Pipeline beschrieben:
```
aws datapipeline describe-pipelines --pipeline-ids df-00627471SOVYZEXAMPLE
```
Das Folgende ist eine Beispielausgabe:
```
{
"pipelineDescriptionList": [
{
"fields": [
{
"stringValue": "PENDING",
"key": "@pipelineState"
},
{
"stringValue": "my-pipeline",
"key": "name"
},
{
"stringValue": "2015-04-07T16:05:58",
"key": "@creationTime"
},
{
"stringValue": "df-00627471SOVYZEXAMPLE",
"key": "@id"
},
{
"stringValue": "123456789012",
"key": "pipelineCreator"
},
{
"stringValue": "PIPELINE",
"key": "@sphere"
},
{
"stringValue": "123456789012",
"key": "@userId"
},
{
"stringValue": "123456789012",
"key": "@accountId"
},
{
"stringValue": "my-pipeline-token",
"key": "uniqueId"
}
],
"pipelineId": "df-00627471SOVYZEXAMPLE",
"name": "my-pipeline",
"tags": []
}
]
}
```
+ Einzelheiten zur API finden Sie [DescribePipelines](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/describe-pipelines.html)in der *AWS CLI Befehlsreferenz*.
### `get-pipeline-definition`
Das folgende Codebeispiel zeigt die Verwendung`get-pipeline-definition`.
**AWS CLI**
**So rufen Sie eine Pipeline-Definition ab**
Dieses Beispiel ruft die Pipeline-Definition für die angegebene Pipeline ab:
```
aws datapipeline get-pipeline-definition --pipeline-id df-00627471SOVYZEXAMPLE
```
Das Folgende ist eine Beispielausgabe:
```
{
"parameters": [
{
"type": "AWS::S3::ObjectKey",
"id": "myS3OutputLoc",
"description": "S3 output folder"
},
{
"default": "s3://us-east-1.elasticmapreduce.samples/pig-apache-logs/data",
"type": "AWS::S3::ObjectKey",
"id": "myS3InputLoc",
"description": "S3 input folder"
},
{
"default": "grep -rc \"GET\" ${INPUT1_STAGING_DIR}/* > ${OUTPUT1_STAGING_DIR}/output.txt",
"type": "String",
"id": "myShellCmd",
"description": "Shell command to run"
}
],
"objects": [
{
"type": "Ec2Resource",
"terminateAfter": "20 Minutes",
"instanceType": "t1.micro",
"id": "EC2ResourceObj",
"name": "EC2ResourceObj"
},
{
"name": "Default",
"failureAndRerunMode": "CASCADE",
"resourceRole": "DataPipelineDefaultResourceRole",
"schedule": {
"ref": "DefaultSchedule"
},
"role": "DataPipelineDefaultRole",
"scheduleType": "cron",
"id": "Default"
},
{
"directoryPath": "#{myS3OutputLoc}/#{format(@scheduledStartTime, 'YYYY-MM-dd-HH-mm-ss')}",
"type": "S3DataNode",
"id": "S3OutputLocation",
"name": "S3OutputLocation"
},
{
"directoryPath": "#{myS3InputLoc}",
"type": "S3DataNode",
"id": "S3InputLocation",
"name": "S3InputLocation"
},
{
"startAt": "FIRST_ACTIVATION_DATE_TIME",
"name": "Every 15 minutes",
"period": "15 minutes",
"occurrences": "4",
"type": "Schedule",
"id": "DefaultSchedule"
},
{
"name": "ShellCommandActivityObj",
"command": "#{myShellCmd}",
"output": {
"ref": "S3OutputLocation"
},
"input": {
"ref": "S3InputLocation"
},
"stage": "true",
"type": "ShellCommandActivity",
"id": "ShellCommandActivityObj",
"runsOn": {
"ref": "EC2ResourceObj"
}
}
],
"values": {
"myS3OutputLoc": "s3://amzn-s3-demo-bucket/",
"myS3InputLoc": "s3://us-east-1.elasticmapreduce.samples/pig-apache-logs/data",
"myShellCmd": "grep -rc \"GET\" ${INPUT1_STAGING_DIR}/* > ${OUTPUT1_STAGING_DIR}/output.txt"
}
}
```
+ Einzelheiten zur API finden Sie [GetPipelineDefinition](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/get-pipeline-definition.html)in der *AWS CLI Befehlsreferenz*.
### `list-pipelines`
Das folgende Codebeispiel zeigt die Verwendung`list-pipelines`.
**AWS CLI**
**So listen Sie Ihre Pipelines auf**
In diesem Beispiel werden Ihre Pipelines aufgelistet:
```
aws datapipeline list-pipelines
```
Das Folgende ist eine Beispielausgabe:
```
{
"pipelineIdList": [
{
"id": "df-00627471SOVYZEXAMPLE",
"name": "my-pipeline"
},
{
"id": "df-09028963KNVMREXAMPLE",
"name": "ImportDDB"
},
{
"id": "df-0870198233ZYVEXAMPLE",
"name": "CrossRegionDDB"
},
{
"id": "df-00189603TB4MZEXAMPLE",
"name": "CopyRedshift"
}
]
}
```
+ Einzelheiten zur API finden Sie [ListPipelines](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/list-pipelines.html)in der *AWS CLI Befehlsreferenz*.
### `list-runs`
Das folgende Codebeispiel zeigt die Verwendung`list-runs`.
**AWS CLI**
**Beispiel 1: So listen Sie Ihre Pipeline-Läufe auf**
Im folgenden Beispiel für `list-runs` werden die Läufe für die angegebene Pipeline aufgelistet.
```
aws datapipeline list-runs --pipeline-id df-00627471SOVYZEXAMPLE
```
Ausgabe:
```
Name Scheduled Start Status ID Started Ended
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
1. EC2ResourceObj 2015-04-12T17:33:02 CREATING @EC2ResourceObj_2015-04-12T17:33:02 2015-04-12T17:33:10
2. S3InputLocation 2015-04-12T17:33:02 FINISHED @S3InputLocation_2015-04-12T17:33:02 2015-04-12T17:33:09 2015-04-12T17:33:09
3. S3OutputLocation 2015-04-12T17:33:02 WAITING_ON_DEPENDENCIES @S3OutputLocation_2015-04-12T17:33:02 2015-04-12T17:33:09
4. ShellCommandActivityObj 2015-04-12T17:33:02 WAITING_FOR_RUNNER @ShellCommandActivityObj_2015-04-12T17:33:02 2015-04-12T17:33:09
```
**Beispiel 2: So listen Sie die Pipeline-Läufe zwischen den angegebenen Daten auf**
Im folgenden Beispiel für `list-runs` wird `--start-interval` verwendet, um die Daten anzugeben, die in die Ausgabe aufgenommen werden sollen.
```
aws datapipeline list-runs --pipeline-id df-01434553B58A2SHZUKO5 --start-interval 2017-10-07T00:00:00,2017-10-08T00:00:00
```
+ Einzelheiten zur API finden Sie [ListRuns](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/list-runs.html)in der *AWS CLI Befehlsreferenz*.
### `put-pipeline-definition`
Das folgende Codebeispiel zeigt die Verwendung`put-pipeline-definition`.
**AWS CLI**
**So laden Sie eine Pipeline-Definition hoch**
Dieses Beispiel lädt die angegebene Pipeline-Definition auf die spezifizierte Pipeline hoch:
```
aws datapipeline put-pipeline-definition --pipeline-id df-00627471SOVYZEXAMPLE --pipeline-definition file://my-pipeline-definition.json
```
Das Folgende ist eine Beispielausgabe:
```
{
"validationErrors": [],
"errored": false,
"validationWarnings": []
}
```
+ Einzelheiten zur API finden Sie [PutPipelineDefinition](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/put-pipeline-definition.html)in der *AWS CLI Befehlsreferenz*.
### `remove-tags`
Das folgende Codebeispiel zeigt die Verwendung`remove-tags`.
**AWS CLI**
**So entfernen Sie ein Tag aus einer Pipeline**
In diesem Beispiel wird das spezifizierte Tag aus der angegebenen Pipeline entfernt:
```
aws datapipeline remove-tags --pipeline-id df-00627471SOVYZEXAMPLE --tag-keys environment
```
+ Einzelheiten zur API finden Sie [RemoveTags](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/datapipeline/remove-tags.html)in der *AWS CLI Befehlsreferenz*.