AWS Data Pipeline tidak lagi tersedia untuk pelanggan baru. Pelanggan yang sudah ada AWS Data Pipeline dapat terus menggunakan layanan seperti biasa. [Pelajari selengkapnya](https://aws.amazon.com/blogs/big-data/migrate-workloads-from-aws-data-pipeline/)
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Simpul Data
Berikut ini adalah objek node AWS Data Pipeline data:
**Topics**
+ [Node Dinamo DBData](dp-object-dynamodbdatanode.md)
+ [MySqlDataNode](dp-object-mysqldatanode.md)
+ [RedshiftDataNode](dp-object-redshiftdatanode.md)
+ [S3 DataNode](dp-object-s3datanode.md)
+ [SqlDataNode](dp-object-sqldatanode.md)
# Node Dinamo DBData
Mendefinisikan simpul data menggunakan DynamoDB, yang ditetapkan sebagai masukan ke objek `HiveActivity` atau `EMRActivity`.
**catatan**
Objek `DynamoDBDataNode` tidak support prasyarat `Exists`.
## Contoh
Berikut adalah contoh dari jenis objek ini. Objek ini mereferensikan dua objek lain yang Anda akan definisikan dalam file definisi alur yang sama. `CopyPeriod` adalah objek `Schedule` dan `Ready` adalah objek prasyarat.
```
{
"id" : "MyDynamoDBTable",
"type" : "DynamoDBDataNode",
"schedule" : { "ref" : "CopyPeriod" },
"tableName" : "adEvents",
"precondition" : { "ref" : "Ready" }
}
```
## Sintaksis
****
| Bidang yang Wajib Diisi | Deskripsi | Jenis Slot |
| --- | --- | --- |
| tableName | Tabel DynamoDB. | String |
****
| Bidang Invokasi Objek | Deskripsi | Jenis Slot |
| --- | --- | --- |
| jadwal | Objek ini dipanggil dalam pelaksanaan interval jadwal. Pengguna harus menentukan referensi jadwal ke objek lain untuk mengatur urutan eksekusi ketergantungan untuk objek ini. Pengguna dapat memenuhi persyaratan ini dengan secara eksplisit mengatur jadwal pada objek, misalnya, dengan menentukan “jadwal”: \$1"ref”: "“\$1. DefaultSchedule Dalam kebanyakan kasus, lebih baik untuk menempatkan referensi jadwal pada objek alur default sehingga semua objek mewarisi jadwal itu. Atau, jika alur memiliki pohon jadwal (jadwal dalam jadwal utama), pengguna dapat membuat objek induk yang memiliki referensi jadwal. Untuk informasi selengkapnya tentang contoh konfigurasi jadwal opsional, lihat [Jadwal](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html). | Objek Referensi, misalnya, “schedule”: \$1"ref”:” myScheduleId “\$1 |
****
| Bidang Opsional | Deskripsi | Jenis Slot |
| --- | --- | --- |
| attemptStatus | Baru-baru ini melaporkan status dari aktivitas jarak jauh. | String |
| attemptTimeout | Timeout untuk penyelesaian pekerjaan jarak jauh. Jika bidang ini disetel, maka aktivitas jarak jauh yang tidak lengkap dalam waktu mulai yang ditetapkan mungkin dicoba lagi. | Periode |
| dataFormat | DataFormat untuk data yang dijelaskan oleh node data ini. Saat ini didukung untuk HiveActivity dan HiveCopyActivity. | Objek Referensi, “DataFormat”: \$1"ref” :"MyDynamo “\$1 DBData FormatId |
| dependsOn | Tentukan ketergantungan pada objek lain yang bisa dijalankan | Objek Referensi, misalnya “DependsOn”: \$1"ref”:” “\$1 myActivityId |
| failureAndRerunModus | Menjelaskan perilaku simpul konsumen ketika dependensi gagal atau menjalankan kembali | Pencacahan |
| lateAfterTimeout | Waktu berlalu setelah alur mulai di mana objek harus menyelesaikan. Hal ini dipicu hanya ketika jenis jadwal tidak disetel ke ondemand. | Periode |
| maxActiveInstances | Jumlah maksimum instans aktif bersamaan dari suatu komponen. Re-runs tidak dihitung terhadap jumlah instans aktif. | Bilangan Bulat |
| maximumRetries | Jumlah maksimum percobaan ulang pada pelanggaran | Bilangan Bulat |
| onFail | Tindakan untuk dijalankan ketika objek saat ini gagal. | Objek Referensi, misalnya “onFail”: \$1"ref”:” “\$1 myActionId |
| onLateAction | Tindakan yang harus dipicu jika objek belum dijadwalkan atau masih belum selesai. | Objek Referensi, misalnya "onLateAction“: \$1" ref”:” myActionId “\$1 |
| onSuccess | Tindakan untuk dijalankan ketika objek saat ini berhasil. | Objek Referensi, misalnya “onSuccess”: \$1"ref”:” “\$1 myActionId |
| induk | Induk dari objek saat ini dari mana slot akan diwariskan. | Objek Referensi, misalnya “induk”: \$1"ref”:” myBaseObject Id "\$1 |
| pipelineLogUri | URI S3 (seperti 's3://BucketName/Key/ ') untuk mengunggah log untuk pipeline. | String |
| prasyarat | Mendefinisikan prasyarat secara opsional. Sebuah simpul data tidak ditandai "READY" sampai semua prasyarat telah terpenuhi. | Objek Referensi, misalnya “prasyarat”: \$1"ref”:” “myPreconditionId\$1 |
| readThroughputPercent | Mengatur tingkat operasi baca untuk menjaga tingkat throughput yang disediakan DynamoDB Anda berada dalam kisaran dialokasikan untuk tabel Anda. Nilainya adalah dua kali lipat antara 0,1 dan 1,0, secara inklusif. | Ganda |
| region | Kode untuk wilayah di mana tabel DynamoDB ada. Misalnya, us-east-1. Ini digunakan oleh HiveActivity ketika melakukan pementasan untuk tabel DynamoDB di Hive. | Pencacahan |
| reportProgressTimeout | Timeout untuk panggilan kerja jarak jauh berturut-turut ke reportProgress. Jika disetel, maka kegiatan jarak jauh yang tidak melaporkan kemajuan untuk jangka waktu tertentu dapat dianggap terhenti dan jadi dicoba lagi. | Periode |
| retryDelay | Durasi timeout antara dua upaya coba lagi. | Periode |
| runsOn | Sumber daya komputasi untuk menjalankan aktivitas atau perintah. Misalnya, instans Amazon EC2 atau klaster Amazon EMR. | Objek Referensi, misalnya “RunsOn”: \$1"ref”:” “\$1 myResourceId |
| scheduleType | Jenis jadwal mengizinkan Anda untuk menentukan apakah objek dalam definisi alur Anda harus dijadwalkan pada awal interval atau akhir interval. Penjadwalan Gaya Deret Waktu berarti instans dijadwalkan pada akhir setiap interval dan Penjadwalan Gaya Cron berarti intans dijadwalkan pada awal setiap interval. Jadwal sesuai permintaan mengizinkan Anda untuk menjalankan alur satu kali per aktivasi. Ini berarti Anda tidak perlu meng-klon atau membuat ulang alur untuk menjalankannya lagi. Jika Anda menggunakan jadwal sesuai permintaan itu harus ditentukan dalam objek default dan harus menjadi satu-satunya scheduleType yang ditentukan untuk objek dalam alur. Untuk menggunakan saluran pipa sesuai permintaan, Anda cukup memanggil ActivatePipeline operasi untuk setiap proses berikutnya. Nilai adalah: cron, ondemand, dan timeseries. | Pencacahan |
| workerGroup | Kelompok pekerja. Ini digunakan untuk tugas perutean. Jika Anda memberikan nilai runsOn dan workerGroup ada, workerGroup diabaikan. | String |
| writeThroughputPercent | Mengatur tingkat operasi tulis untuk menjaga tingkat throughput yang disediakan DynamoDB Anda berada dalam kisaran yang dialokasikan untuk tabel Anda. Nilainya adalah dua kali lipat antara 0,1 dan 1,0, secara inklusif. | Ganda |
****
| Bidang Runtime | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @activeInstances | Daftar objek instans aktif terjadwal saat ini. | Objek Referensi, misalnya “ActiveInstances”: \$1"ref”:” Id "\$1 myRunnableObject |
| @actualEndTime | Waktu ketika eksekusi objek ini selesai. | DateTime |
| @actualStartTime | Waktu ketika eksekusi objek ini dimulai. | DateTime |
| cancellationReason | cancellationReason jika objek ini dibatalkan. | String |
| @cascadeFailedOn | Deskripsi rantai ketergantungan tempat objek gagal. | Objek Referensi, misalnya "cascadeFailedOn“: \$1" ref”:” myRunnableObject Id "\$1 |
| emrStepLog | Log langkah EMR hanya tersedia pada upaya aktivitas EMR | String |
| errorId | errorId jika objek ini gagal. | String |
| errorMessage | errorMessage jika objek ini gagal. | String |
| errorStackTrace | Jejak tumpukan kesalahan jika objek ini gagal. | String |
| @finishedTime | Waktu saat objek ini menyelesaikan eksekusinya. | DateTime |
| hadoopJobLog | log tugas Hadoop tersedia pada upaya untuk kegiatan berbasis EMR. | String |
| @healthStatus | Status kondisi objek yang mencerminkan keberhasilan atau kegagalan instans objek terakhir yang mencapai keadaan dihentikan. | String |
| @healthStatusFromInstanceId | Id dari objek instans terakhir yang mencapai keadaan dihentikan. | String |
| @ healthStatusUpdated Waktu | Waktu di mana status kondisi diperbarui terakhir kali. | DateTime |
| hostname | Nama host klien yang mengambil upaya tugas. | String |
| @lastDeactivatedTime | Waktu di mana objek ini terakhir dinonaktifkan. | DateTime |
| @ latestCompletedRun Waktu | Waktu proses terakhir yang eksekusinya selesai. | DateTime |
| @latestRunTime | Waktu proses terakhir untuk eksekusi yang dijadwalkan. | DateTime |
| @nextRunTime | Waktu run yang akan dijadwalkan berikutnya. | DateTime |
| reportProgressTime | Waktu terbaru bahwa aktivitas jarak jauh melaporkan kemajuan. | DateTime |
| @scheduledEndTime | Jadwalkan waktu akhir untuk objek | DateTime |
| @scheduledStartTime | Jadwalkan waktu mulai untuk objek | DateTime |
| @status | Status objek ini. | String |
| @version | Versi alur objek dibuat dengan. | String |
| @waitingOn | Deskripsi daftar dependensi objek ini sedang menunggu. | Objek Referensi, misalnya “WaitingOn”: \$1"ref”:” Id "\$1 myRunnableObject |
****
| Bidang Sistem | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @error | Galat mendeskripsikan obyek yang tidak terbentuk | String |
| @pipelineId | Id dari alur tempat objek ini berada | String |
| @sphere | Lingkup dari sebuah objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects yang mengeksekusi Attempt Objects | String |
# MySqlDataNode
Mendefinisikan simpul data menggunakan MySQL.
**catatan**
Jenis `MySqlDataNode` tidak lagi digunakan. Sebagai gantinya, kami rekomendasikan Anda menggunakan [SqlDataNode](dp-object-sqldatanode.md).
## Contoh
Berikut adalah contoh dari jenis objek ini. Objek ini mereferensikan dua objek lain yang Anda akan definisikan dalam file definisi alur yang sama. `CopyPeriod` adalah objek `Schedule` dan `Ready` adalah objek prasyarat.
```
{
"id" : "Sql Table",
"type" : "MySqlDataNode",
"schedule" : { "ref" : "CopyPeriod" },
"table" : "adEvents",
"username": "user_name",
"*password": "my_password",
"connectionString": "jdbc:mysql://mysqlinstance-rds.example.us-east-1.rds.amazonaws.com:3306/database_name",
"selectQuery" : "select * from #{table} where eventTime >= '#{@scheduledStartTime.format('YYYY-MM-dd HH:mm:ss')}' and eventTime < '#{@scheduledEndTime.format('YYYY-MM-dd HH:mm:ss')}'",
"precondition" : { "ref" : "Ready" }
}
```
### Sintaksis
****
| Bidang yang Wajib Diisi | Deskripsi | Jenis Slot |
| --- | --- | --- |
| tabel | Nama tabel dalam basis data MySQL. | String |
****
| Bidang Invokasi Objek | Deskripsi | Jenis Slot |
| --- | --- | --- |
| jadwal | Objek ini dipanggil dalam pelaksanaan interval jadwal. Pengguna harus menentukan referensi jadwal ke objek lain untuk mengatur urutan eksekusi ketergantungan untuk objek ini. Pengguna dapat memenuhi persyaratan ini dengan secara eksplisit mengatur jadwal pada objek, misalnya, dengan menentukan “jadwal”: \$1"ref”: "“\$1. DefaultSchedule Dalam kebanyakan kasus, lebih baik untuk menempatkan referensi jadwal pada objek alur default sehingga semua objek mewarisi jadwal itu. Atau, jika alur memiliki pohon jadwal (jadwal dalam jadwal utama), pengguna dapat membuat objek induk yang memiliki referensi jadwal. Untuk informasi selengkapnya tentang konfigurasi jadwal opsional contoh, lihat [https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html) | Objek Referensi, misalnya “schedule”: \$1"ref”:” myScheduleId “\$1 |
****
| Bidang Opsional | Deskripsi | Jenis Slot |
| --- | --- | --- |
| attemptStatus | Baru-baru ini melaporkan status dari aktivitas jarak jauh. | String |
| attemptTimeout | Timeout untuk penyelesaian pekerjaan jarak jauh. Jika disetel maka aktivitas jarak jauh yang tidak selesai dalam waktu mulai yang ditetapkan dapat dicoba lagi. | Periode |
| createTableSql | SQL membuat ekspresi tabel yang menciptakan tabel. | String |
| basis data | Nama basis data. | Objek Referensi, misalnya “database”: \$1"ref”:” myDatabaseId “\$1 |
| dependsOn | Menentukan dependensi pada objek lain yang bisa dijalankan. | Objek Referensi, misalnya “DependsOn”: \$1"ref”:” “\$1 myActivityId |
| failureAndRerunModus | Menjelaskan perilaku simpul konsumen ketika dependensi gagal atau menjalankan kembali. | Pencacahan |
| insertQuery | Sebuah pernyataan SQL untuk memasukkan data ke dalam tabel. | String |
| lateAfterTimeout | Waktu berlalu setelah alur mulai di mana objek harus menyelesaikan. Hal ini dipicu hanya ketika jenis jadwal tidak disetel ke ondemand. | Periode |
| maxActiveInstances | Jumlah maksimum instans aktif bersamaan dari suatu komponen. Re-runs tidak dihitung terhadap jumlah instans aktif. | Bilangan Bulat |
| maximumRetries | Jumlah maksimum percobaan ulang pada pelanggaran | Bilangan Bulat |
| onFail | Tindakan untuk dijalankan ketika objek saat ini gagal. | Objek Referensi, misalnya “onFail”: \$1"ref”:” “\$1 myActionId |
| onLateAction | Tindakan yang harus dipicu jika objek belum dijadwalkan atau masih belum selesai. | Objek Referensi, misalnya "onLateAction“: \$1" ref”:” myActionId “\$1 |
| onSuccess | Tindakan untuk dijalankan ketika objek saat ini berhasil. | Objek Referensi, misalnya “onSuccess”: \$1"ref”:” “\$1 myActionId |
| induk | Induk dari objek saat ini dari mana slot akan diwariskan. | Objek Referensi, misalnya “induk”: \$1"ref”:” myBaseObject Id "\$1 |
| pipelineLogUri | URI S3 (seperti 's3://BucketName/Key/ ') untuk mengunggah log untuk pipeline. | String |
| prasyarat | Mendefinisikan prasyarat secara opsional. Sebuah simpul data tidak ditandai "READY" sampai semua prasyarat telah terpenuhi. | Objek Referensi, misalnya “prasyarat”: \$1"ref”:” “myPreconditionId\$1 |
| reportProgressTimeout | Timeout untuk panggilan kerja jarak jauh berturut-turut ke reportProgress. Jika disetel, maka kegiatan jarak jauh yang tidak melaporkan kemajuan untuk jangka waktu tertentu dapat dianggap terhenti dan jadi dicoba lagi. | Periode |
| retryDelay | Durasi timeout antara dua upaya coba lagi. | Periode |
| runsOn | Sumber daya komputasi untuk menjalankan aktivitas atau perintah. Misalnya, instans Amazon EC2 atau klaster Amazon EMR. | Objek Referensi, misalnya “RunsOn”: \$1"ref”:” “\$1 myResourceId |
| scheduleType | Jenis jadwal mengizinkan Anda untuk menentukan apakah objek dalam definisi alur Anda harus dijadwalkan pada awal interval atau akhir interval. Penjadwalan Gaya Deret Waktu berarti instans dijadwalkan pada akhir setiap interval dan Penjadwalan Gaya Cron berarti intans dijadwalkan pada awal setiap interval. Jadwal sesuai permintaan mengizinkan Anda untuk menjalankan alur satu kali per aktivasi. Ini berarti Anda tidak perlu meng-klon atau membuat ulang alur untuk menjalankannya lagi. Jika Anda menggunakan jadwal sesuai permintaan itu harus ditentukan dalam objek default dan harus menjadi satu-satunya scheduleType yang ditentukan untuk objek dalam alur. Untuk menggunakan saluran pipa sesuai permintaan, Anda cukup memanggil ActivatePipeline operasi untuk setiap proses berikutnya. Nilai adalah: cron, ondemand, dan timeseries. | Pencacahan |
| schemaName | Nama skema yang memegang tabel | String |
| selectQuery | Sebuah pernyataan SQL untuk mengambil data dari tabel. | String |
| workerGroup | Kelompok pekerja. Ini digunakan untuk tugas perutean. Jika Anda memberikan nilai runsOn dan workerGroup ada, workerGroup diabaikan. | String |
****
| Bidang Runtime | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @activeInstances | Daftar objek instans aktif terjadwal saat ini. | Objek Referensi, misalnya “ActiveInstances”: \$1"ref”:” Id "\$1 myRunnableObject |
| @actualEndTime | Waktu ketika eksekusi objek ini selesai. | DateTime |
| @actualStartTime | Waktu ketika eksekusi objek ini dimulai. | DateTime |
| cancellationReason | cancellationReason jika objek ini dibatalkan. | String |
| @cascadeFailedOn | Deskripsi rantai dependensi tempat objek gagal. | Objek Referensi, misalnya "cascadeFailedOn“: \$1" ref”:” myRunnableObject Id "\$1 |
| emrStepLog | Log langkah EMR hanya tersedia pada upaya aktivitas EMR | String |
| errorId | errorId jika objek ini gagal. | String |
| errorMessage | errorMessage jika objek ini gagal. | String |
| errorStackTrace | Jejak tumpukan kesalahan jika objek ini gagal. | String |
| @finishedTime | Waktu saat objek ini menyelesaikan eksekusinya. | DateTime |
| hadoopJobLog | log tugas Hadoop tersedia pada upaya untuk kegiatan berbasis EMR. | String |
| @healthStatus | Status kondisi objek yang mencerminkan keberhasilan atau kegagalan instans objek terakhir yang mencapai keadaan dihentikan. | String |
| @healthStatusFromInstanceId | Id dari objek instans terakhir yang mencapai keadaan dihentikan. | String |
| @ healthStatusUpdated Waktu | Waktu di mana status kondisi diperbarui terakhir kali. | DateTime |
| hostname | Nama host klien yang mengambil upaya tugas. | String |
| @lastDeactivatedTime | Waktu di mana objek ini terakhir dinonaktifkan. | DateTime |
| @ latestCompletedRun Waktu | Waktu proses terakhir yang eksekusinya selesai. | DateTime |
| @latestRunTime | Waktu proses terakhir untuk eksekusi yang dijadwalkan. | DateTime |
| @nextRunTime | Waktu run yang akan dijadwalkan berikutnya. | DateTime |
| reportProgressTime | Waktu terbaru bahwa aktivitas jarak jauh melaporkan kemajuan. | DateTime |
| @scheduledEndTime | Jadwalkan akhir waktu untuk objek. | DateTime |
| @scheduledStartTime | Jadwalkan waktu mulai untuk objek. | DateTime |
| @status | Status objek ini. | String |
| @version | Versi alur objek dibuat dengan. | String |
| @waitingOn | Deskripsi daftar dependensi objek ini sedang menunggu. | Objek Referensi, misalnya “WaitingOn”: \$1"ref”:” Id "\$1 myRunnableObject |
****
| Bidang Sistem | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @error | Galat menggambarkan objek yang tidak terbentuk. | String |
| @pipelineId | Id dari alur tempat objek ini berada. | String |
| @sphere | Lingkup objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects yang mengeksekusi Attempt Objects. | String |
## Lihat Juga
+ [S3 DataNode](dp-object-s3datanode.md)
# RedshiftDataNode
Mendefinisikan simpul data menggunakan Amazon Redshift. `RedshiftDataNode`mewakili properti data di dalam basis data, seperti tabel data, yang digunakan oleh alur Anda.
## Contoh
Berikut adalah contoh dari jenis objek ini.
```
{
"id" : "MyRedshiftDataNode",
"type" : "RedshiftDataNode",
"database": { "ref": "MyRedshiftDatabase" },
"tableName": "adEvents",
"schedule": { "ref": "Hour" }
}
```
## Sintaksis
****
| Bidang yang Wajib Diisi | Deskripsi | Jenis Slot |
| --- | --- | --- |
| basis data | Basis data tempat tabel berada. | Objek Referensi, misalnya “database”: \$1"ref”:” myRedshiftDatabase Id "\$1 |
| tableName | Nama tabel Amazon Redshift. Tabel dibuat jika belum ada dan Anda telah menyediakan createTableSql. | String |
****
| Bidang Invokasi Objek | Deskripsi | Jenis Slot |
| --- | --- | --- |
| jadwal | Objek ini dipanggil dalam pelaksanaan interval jadwal. Pengguna harus menentukan referensi jadwal ke objek lain untuk mengatur urutan eksekusi ketergantungan untuk objek ini. Pengguna dapat memenuhi persyaratan ini dengan secara eksplisit mengatur jadwal pada objek, misalnya, dengan menentukan “jadwal”: \$1"ref”: "“\$1. DefaultSchedule Dalam kebanyakan kasus, lebih baik untuk menempatkan referensi jadwal pada objek alur default sehingga semua objek mewarisi jadwal itu. Atau, jika alur memiliki pohon jadwal (jadwal dalam jadwal utama), pengguna dapat membuat objek induk yang memiliki referensi jadwal. Untuk informasi selengkapnya tentang konfigurasi jadwal opsional contoh, lihat [https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html) | Objek Referensi, misalnya “schedule”: \$1"ref”:” myScheduleId “\$1 |
****
| Bidang Opsional | Deskripsi | Jenis Slot |
| --- | --- | --- |
| attemptStatus | Baru-baru ini melaporkan status dari aktivitas jarak jauh. | String |
| attemptTimeout | Timeout untuk penyelesaian pekerjaan jarak jauh. Jika disetel maka aktivitas jarak jauh yang tidak selesai dalam waktu mulai yang ditetapkan dapat dicoba lagi. | Periode |
| createTableSql | Ekspresi SQL untuk membuat tabel dalam basis data. Kami menyarankan Anda menentukan skema di mana tabel harus dibuat, misalnya: CREATE TABLE MySchema.myTable (bestColumn varchar (25) primary key distkey, integer sortKey). numberOfWins AWS Data Pipeline menjalankan skrip di createTableSql bidang jika tabel, ditentukan oleh TableName, tidak ada dalam skema, ditentukan oleh bidang schemaName. Misalnya, jika Anda menentukan schemaName sebagai MySchema tetapi tidak menyertakan mySchema di createTableSql bidang, tabel dibuat dalam skema yang salah (secara default, itu akan dibuat di PUBLIC). Hal ini terjadi karena AWS Data Pipeline tidak mengurai pernyataan CREATE TABLE Anda. | String |
| dependsOn | Tentukan ketergantungan pada objek lain yang bisa dijalankan | Objek Referensi, misalnya “DependsOn”: \$1"ref”:” “\$1 myActivityId |
| failureAndRerunModus | Menjelaskan perilaku simpul konsumen ketika dependensi gagal atau menjalankan kembali | Pencacahan |
| lateAfterTimeout | Waktu berlalu setelah alur mulai di mana objek harus menyelesaikan. Hal ini dipicu hanya ketika jenis jadwal tidak disetel ke ondemand. | Periode |
| maxActiveInstances | Jumlah maksimum instans aktif bersamaan dari suatu komponen. Re-runs tidak dihitung terhadap jumlah instans aktif. | Bilangan Bulat |
| maximumRetries | Upaya jumlah maksimum mencoba lagi pada kegagalan. | Bilangan Bulat |
| onFail | Tindakan untuk dijalankan ketika objek saat ini gagal. | Objek Referensi, misalnya “onFail”: \$1"ref”:” “\$1 myActionId |
| onLateAction | Tindakan yang harus dipicu jika objek belum dijadwalkan atau masih belum selesai. | Objek Referensi, misalnya "onLateAction“: \$1" ref”:” myActionId “\$1 |
| onSuccess | Tindakan untuk dijalankan ketika objek saat ini berhasil. | Objek Referensi, misalnya “onSuccess”: \$1"ref”:” “\$1 myActionId |
| induk | Induk dari objek saat ini dari mana slot akan diwariskan. | Objek Referensi, misalnya “induk”: \$1"ref”:” myBaseObject Id "\$1 |
| pipelineLogUri | URI S3 (seperti 's3://BucketName/Key/ ') untuk mengunggah log untuk pipeline. | String |
| prasyarat | Mendefinisikan prasyarat secara opsional. Sebuah simpul data tidak ditandai "READY" sampai semua prasyarat telah terpenuhi. | Objek Referensi, misalnya “prasyarat”: \$1"ref”:” “myPreconditionId\$1 |
| primaryKeys | Jika Anda tidak menentukan primaryKeys untuk tabel tujuan di RedShiftCopyActivity, Anda dapat menentukan daftar kolom menggunakan primaryKeys yang akan bertindak sebagai mergeKey. Namun, jika Anda memiliki primaryKey yang ada yang didefinisikan dalam tabel Amazon Redshift, pengaturan ini menimpa kunci yang ada. | String |
| reportProgressTimeout | Timeout untuk panggilan kerja jarak jauh berturut-turut ke reportProgress. Jika disetel, maka kegiatan jarak jauh yang tidak melaporkan kemajuan untuk jangka waktu tertentu dapat dianggap terhenti dan jadi dicoba lagi. | Periode |
| retryDelay | Durasi timeout antara dua upaya coba lagi. | Periode |
| runsOn | Sumber daya komputasi untuk menjalankan aktivitas atau perintah. Misalnya, instans Amazon EC2 atau klaster Amazon EMR. | Objek Referensi, misalnya “RunsOn”: \$1"ref”:” “\$1 myResourceId |
| scheduleType | Jenis jadwal mengizinkan Anda untuk menentukan apakah objek dalam definisi alur Anda harus dijadwalkan pada awal interval atau akhir interval. Penjadwalan Gaya Deret Waktu berarti instans dijadwalkan pada akhir setiap interval dan Penjadwalan Gaya Cron berarti intans dijadwalkan pada awal setiap interval. Jadwal sesuai permintaan mengizinkan Anda untuk menjalankan alur satu kali per aktivasi. Ini berarti Anda tidak perlu meng-klon atau membuat ulang alur untuk menjalankannya lagi. Jika Anda menggunakan jadwal sesuai permintaan itu harus ditentukan dalam objek default dan harus menjadi satu-satunya scheduleType yang ditentukan untuk objek dalam alur. Untuk menggunakan saluran pipa sesuai permintaan, Anda cukup memanggil ActivatePipeline operasi untuk setiap proses berikutnya. Nilai adalah: cron, ondemand, dan timeseries. | Pencacahan |
| schemaName | Bidang opsional ini menentukan nama skema untuk tabel Amazon Redshift. Jika tidak ditentukan, nama skemanya adalah PUBLIK, yang merupakan skema default di Amazon Redshift. Untuk informasi selengkapnya, lihat Panduan Developer Basis Data Amazon Redshift. | String |
| workerGroup | Kelompok pekerja. Ini digunakan untuk tugas perutean. Jika Anda memberikan nilai runsOn dan workerGroup ada, workerGroup diabaikan. | String |
****
| Bidang Runtime | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @activeInstances | Daftar objek instans aktif terjadwal saat ini. | Objek Referensi, misalnya “ActiveInstances”: \$1"ref”:” Id "\$1 myRunnableObject |
| @actualEndTime | Waktu ketika eksekusi objek ini selesai. | DateTime |
| @actualStartTime | Waktu ketika eksekusi objek ini dimulai. | DateTime |
| cancellationReason | cancellationReason jika objek ini dibatalkan. | String |
| @cascadeFailedOn | Deskripsi rantai dependensi tempat objek gagal. | Objek Referensi, misalnya "cascadeFailedOn“: \$1" ref”:” myRunnableObject Id "\$1 |
| emrStepLog | Log langkah EMR hanya tersedia pada upaya aktivitas EMR | String |
| errorId | errorId jika objek ini gagal. | String |
| errorMessage | errorMessage jika objek ini gagal. | String |
| errorStackTrace | Jejak tumpukan kesalahan jika objek ini gagal. | String |
| @finishedTime | Waktu saat objek ini menyelesaikan eksekusinya. | DateTime |
| hadoopJobLog | log tugas Hadoop tersedia pada upaya untuk kegiatan berbasis EMR. | String |
| @healthStatus | Status kondisi objek yang mencerminkan keberhasilan atau kegagalan instans objek terakhir yang mencapai keadaan dihentikan. | String |
| @healthStatusFromInstanceId | Id dari objek instans terakhir yang mencapai keadaan dihentikan. | String |
| @ healthStatusUpdated Waktu | Waktu di mana status kondisi diperbarui terakhir kali. | DateTime |
| hostname | Nama host klien yang mengambil upaya tugas. | String |
| @lastDeactivatedTime | Waktu di mana objek ini terakhir dinonaktifkan. | DateTime |
| @ latestCompletedRun Waktu | Waktu proses terakhir yang eksekusinya selesai. | DateTime |
| @latestRunTime | Waktu proses terakhir untuk eksekusi yang dijadwalkan. | DateTime |
| @nextRunTime | Waktu run yang akan dijadwalkan berikutnya. | DateTime |
| reportProgressTime | Waktu terbaru bahwa aktivitas jarak jauh melaporkan kemajuan. | DateTime |
| @scheduledEndTime | Jadwalkan waktu akhir untuk objek | DateTime |
| @scheduledStartTime | Jadwalkan waktu mulai untuk objek | DateTime |
| @status | Status objek ini. | String |
| @version | Versi alur objek dibuat dengan. | String |
| @waitingOn | Deskripsi daftar dependensi objek ini sedang menunggu. | Objek Referensi, misalnya “WaitingOn”: \$1"ref”:” Id "\$1 myRunnableObject |
****
| Bidang Sistem | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @error | Galat menggambarkan objek yang tidak terbentuk. | String |
| @pipelineId | Id dari alur tempat objek ini berada. | String |
| @sphere | Lingkup objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects yang mengeksekusi Attempt Objects. | String |
# S3 DataNode
Mendefinisikan simpul data menggunakan Amazon S3. Secara default, S3 DataNode menggunakan enkripsi sisi server. Jika Anda ingin menonaktifkan ini, setel s3 EncryptionType ke NONE.
**catatan**
Saat Anda menggunakan `S3DataNode` sebagai masukan ke `CopyActivity`, hanya format data CSV dan TSV yang disupport.
## Contoh
Berikut adalah contoh dari jenis objek ini. Objek ini mereferensikan objek lain yang Anda akan definisikan dalam file definisi alur yang sama. `CopyPeriod` adalah objek `Schedule`.
```
{
"id" : "OutputData",
"type" : "S3DataNode",
"schedule" : { "ref" : "CopyPeriod" },
"filePath" : "s3://amzn-s3-demo-bucket/#{@scheduledStartTime}.csv"
}
```
## Sintaksis
****
| Bidang Invokasi Objek | Deskripsi | Jenis Slot |
| --- | --- | --- |
| jadwal | Objek ini dipanggil dalam pelaksanaan interval jadwal. Pengguna harus menentukan referensi jadwal ke objek lain untuk mengatur urutan eksekusi ketergantungan untuk objek ini. Pengguna dapat memenuhi persyaratan ini dengan secara eksplisit mengatur jadwal pada objek, misalnya, dengan menentukan “jadwal”: \$1"ref”: "“\$1. DefaultSchedule Dalam kebanyakan kasus, lebih baik untuk menempatkan referensi jadwal pada objek alur default sehingga semua objek mewarisi jadwal itu. Atau, jika alur memiliki pohon jadwal (jadwal dalam jadwal utama), pengguna dapat membuat objek induk yang memiliki referensi jadwal. Untuk informasi selengkapnya tentang konfigurasi jadwal opsional contoh, lihat [https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html) | Objek Referensi, misalnya “schedule”: \$1"ref”:” myScheduleId “\$1 |
****
| Bidang Opsional | Deskripsi | Jenis Slot |
| --- | --- | --- |
| attemptStatus | Baru-baru ini melaporkan status dari aktivitas jarak jauh. | String |
| attemptTimeout | Timeout untuk penyelesaian pekerjaan jarak jauh. Jika disetel maka aktivitas jarak jauh yang tidak selesai dalam waktu mulai yang ditetapkan dapat dicoba lagi. | Periode |
| Kompresi | Jenis kompresi untuk data yang dijelaskan oleh S3DataNode. “none” tidak ada kompresi dan “gzip” dikompresi dengan algoritma gzip. Bidang ini hanya didukung untuk digunakan dengan Amazon Redshift dan saat Anda menggunakan DataNode S3 dengan. CopyActivity | Pencacahan |
| dataFormat | DataFormat untuk data yang dijelaskan oleh S3 DataNode ini. | Objek Referensi, misalnya “DataFormat”: \$1"ref”:” myDataFormat Id "\$1 |
| dependsOn | Tentukan ketergantungan pada objek lain yang bisa dijalankan | Objek Referensi, misalnya “DependsOn”: \$1"ref”:” “\$1 myActivityId |
| directoryPath | Jalur direktori Amazon S3 sebagai URI: s3://my-bucket/. my-key-for-directory Anda harus memberikan nilai filePath atau directoryPath. | String |
| failureAndRerunModus | Menjelaskan perilaku simpul konsumen ketika dependensi gagal atau menjalankan kembali | Pencacahan |
| filePath | Jalur ke objek di Amazon S3 sebagai URI, misalnya: s3://my-bucket/. my-key-for-file Anda harus memberikan nilai filePath atau directoryPath. Ini mewakili folder dan nama file. Gunakan nilai directoryPath untuk mengakomodasi beberapa file dalam direktori. | String |
| lateAfterTimeout | Waktu berlalu setelah alur mulai di mana objek harus menyelesaikan. Hal ini dipicu hanya ketika jenis jadwal tidak disetel ke ondemand. | Periode |
| manifestFilePath | Jalur Amazon S3 ke file manifes dalam format yang didukung oleh Amazon Redshift. AWS Data Pipeline menggunakan file manifes untuk menyalin file Amazon S3 yang ditentukan ke dalam tabel. Bidang ini hanya valid ketika RedShiftCopyActivity referensi S3DataNode. | String |
| maxActiveInstances | Jumlah maksimum instans aktif bersamaan dari suatu komponen. Re-runs tidak dihitung terhadap jumlah instans aktif. | Bilangan Bulat |
| maximumRetries | Jumlah maksimum percobaan ulang pada pelanggaran | Bilangan Bulat |
| onFail | Tindakan untuk dijalankan ketika objek saat ini gagal. | Objek Referensi, misalnya “onFail”: \$1"ref”:” “\$1 myActionId |
| onLateAction | Tindakan yang harus dipicu jika objek belum dijadwalkan atau masih belum selesai. | Objek Referensi, misalnya "onLateAction“: \$1" ref”:” myActionId “\$1 |
| onSuccess | Tindakan untuk dijalankan ketika objek saat ini berhasil. | Objek Referensi, misalnya “onSuccess”: \$1"ref”:” “\$1 myActionId |
| induk | Induk dari objek saat ini dari mana slot akan diwariskan. | Objek Referensi, misalnya “induk”: \$1"ref”:” myBaseObject Id "\$1 |
| pipelineLogUri | URI S3 (seperti 's3://BucketName/Key/ ') untuk mengunggah log untuk pipeline. | String |
| prasyarat | Mendefinisikan prasyarat secara opsional. Sebuah simpul data tidak ditandai "READY" sampai semua prasyarat telah terpenuhi. | Objek Referensi, misalnya “prasyarat”: \$1"ref”:” “myPreconditionId\$1 |
| reportProgressTimeout | Timeout untuk panggilan kerja jarak jauh berturut-turut ke reportProgress. Jika disetel, maka kegiatan jarak jauh yang tidak melaporkan kemajuan untuk jangka waktu tertentu dapat dianggap terhenti dan jadi dicoba lagi. | Periode |
| retryDelay | Durasi timeout antara dua upaya coba lagi. | Periode |
| runsOn | Sumber daya komputasi untuk menjalankan aktivitas atau perintah. Misalnya, instans Amazon EC2 atau klaster Amazon EMR. | Objek Referensi, misalnya “RunsOn”: \$1"ref”:” “\$1 myResourceId |
| s3 EncryptionType | Mengganti jenis enkripsi Amazon S3. Nilai adalah SERVER\$1SIDE\$1ENCRYPTION atau NONE. Enkripsi sisi server diaktifkan secara default. | Pencacahan |
| scheduleType | Jenis jadwal mengizinkan Anda untuk menentukan apakah objek dalam definisi alur Anda harus dijadwalkan pada awal interval atau akhir interval. Penjadwalan Gaya Deret Waktu berarti instans dijadwalkan pada akhir setiap interval dan Penjadwalan Gaya Cron berarti intans dijadwalkan pada awal setiap interval. Jadwal sesuai permintaan mengizinkan Anda untuk menjalankan alur satu kali per aktivasi. Ini berarti Anda tidak perlu meng-klon atau membuat ulang alur untuk menjalankannya lagi. Jika Anda menggunakan jadwal sesuai permintaan itu harus ditentukan dalam objek default dan harus menjadi satu-satunya scheduleType yang ditentukan untuk objek dalam alur. Untuk menggunakan saluran pipa sesuai permintaan, Anda cukup memanggil ActivatePipeline operasi untuk setiap proses berikutnya. Nilai adalah: cron, ondemand, dan timeseries. | Pencacahan |
| workerGroup | Kelompok pekerja. Ini digunakan untuk tugas perutean. Jika Anda memberikan nilai runsOn dan workerGroup ada, workerGroup diabaikan. | String |
****
| Bidang Runtime | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @activeInstances | Daftar objek instans aktif terjadwal saat ini. | Objek Referensi, misalnya “ActiveInstances”: \$1"ref”:” Id "\$1 myRunnableObject |
| @actualEndTime | Waktu ketika eksekusi objek ini selesai. | DateTime |
| @actualStartTime | Waktu ketika eksekusi objek ini dimulai. | DateTime |
| cancellationReason | cancellationReason jika objek ini dibatalkan. | String |
| @cascadeFailedOn | Deskripsi rantai dependensi tempat objek gagal. | Objek Referensi, misalnya "cascadeFailedOn“: \$1" ref”:” myRunnableObject Id "\$1 |
| emrStepLog | Log langkah EMR hanya tersedia pada upaya aktivitas EMR | String |
| errorId | errorId jika objek ini gagal. | String |
| errorMessage | errorMessage jika objek ini gagal. | String |
| errorStackTrace | Jejak tumpukan kesalahan jika objek ini gagal. | String |
| @finishedTime | Waktu saat objek ini menyelesaikan eksekusinya. | DateTime |
| hadoopJobLog | log tugas Hadoop tersedia pada upaya untuk kegiatan berbasis EMR. | String |
| @healthStatus | Status kondisi objek yang mencerminkan keberhasilan atau kegagalan instans objek terakhir yang mencapai keadaan dihentikan. | String |
| @healthStatusFromInstanceId | Id dari objek instans terakhir yang mencapai keadaan dihentikan. | String |
| @ healthStatusUpdated Waktu | Waktu di mana status kondisi diperbarui terakhir kali. | DateTime |
| hostname | Nama host klien yang mengambil upaya tugas. | String |
| @lastDeactivatedTime | Waktu di mana objek ini terakhir dinonaktifkan. | DateTime |
| @ latestCompletedRun Waktu | Waktu proses terakhir yang eksekusinya selesai. | DateTime |
| @latestRunTime | Waktu proses terakhir untuk eksekusi yang dijadwalkan. | DateTime |
| @nextRunTime | Waktu run yang akan dijadwalkan berikutnya. | DateTime |
| reportProgressTime | Waktu terbaru bahwa aktivitas jarak jauh melaporkan kemajuan. | DateTime |
| @scheduledEndTime | Jadwalkan waktu akhir untuk objek | DateTime |
| @scheduledStartTime | Jadwalkan waktu mulai untuk objek | DateTime |
| @status | Status objek ini. | String |
| @version | Versi alur objek dibuat dengan. | String |
| @waitingOn | Deskripsi daftar dependensi objek ini sedang menunggu. | Objek Referensi, misalnya “WaitingOn”: \$1"ref”:” Id "\$1 myRunnableObject |
****
| Bidang Sistem | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @error | Galat mendeskripsikan obyek yang tidak terbentuk | String |
| @pipelineId | Id dari alur tempat objek ini berada | String |
| @sphere | Lingkup dari sebuah objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects yang mengeksekusi Attempt Objects | String |
## Lihat Juga
+ [MySqlDataNode](dp-object-mysqldatanode.md)
# SqlDataNode
Mendefinisikan simpul data menggunakan SQL.
## Contoh
Berikut adalah contoh dari jenis objek ini. Objek ini mereferensikan dua objek lain yang Anda akan definisikan dalam file definisi alur yang sama. `CopyPeriod` adalah objek `Schedule` dan `Ready` adalah objek prasyarat.
```
{
"id" : "Sql Table",
"type" : "SqlDataNode",
"schedule" : { "ref" : "CopyPeriod" },
"table" : "adEvents",
"database":"myDataBaseName",
"selectQuery" : "select * from #{table} where eventTime >= '#{@scheduledStartTime.format('YYYY-MM-dd HH:mm:ss')}' and eventTime < '#{@scheduledEndTime.format('YYYY-MM-dd HH:mm:ss')}'",
"precondition" : { "ref" : "Ready" }
}
```
## Sintaksis
****
| Bidang yang Wajib Diisi | Deskripsi | Jenis Slot |
| --- | --- | --- |
| tabel | Nama tabel dalam basis data SQL. | String |
****
| Bidang Invokasi Objek | Deskripsi | Jenis Slot |
| --- | --- | --- |
| jadwal | Objek ini dipanggil dalam pelaksanaan interval jadwal. Pengguna harus menentukan referensi jadwal ke objek lain untuk mengatur urutan eksekusi ketergantungan untuk objek ini. Pengguna dapat memenuhi persyaratan ini dengan secara eksplisit mengatur jadwal pada objek, misalnya, dengan menentukan “jadwal”: \$1"ref”: "“\$1. DefaultSchedule Dalam kebanyakan kasus, lebih baik untuk menempatkan referensi jadwal pada objek alur default sehingga semua objek mewarisi jadwal itu. Atau, jika alur memiliki pohon jadwal (jadwal dalam jadwal utama), pengguna dapat membuat objek induk yang memiliki referensi jadwal. Untuk informasi selengkapnya tentang konfigurasi jadwal opsional contoh, lihat [https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html](https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-object-schedule.html) | Objek Referensi, misalnya “schedule”: \$1"ref”:” myScheduleId “\$1 |
****
| Bidang Opsional | Deskripsi | Jenis Slot |
| --- | --- | --- |
| attemptStatus | Baru-baru ini melaporkan status dari aktivitas jarak jauh. | String |
| attemptTimeout | Timeout untuk penyelesaian pekerjaan jarak jauh. Jika disetel maka aktivitas jarak jauh yang tidak selesai dalam waktu mulai yang ditetapkan dapat dicoba lagi. | Periode |
| createTableSql | SQL membuat ekspresi tabel yang menciptakan tabel. | String |
| basis data | Nama basis data. | Objek Referensi, misalnya “database”: \$1"ref”:” myDatabaseId “\$1 |
| dependsOn | Menentukan dependensi pada objek yang bisa dijalankan lainnya. | Objek Referensi, misalnya “DependsOn”: \$1"ref”:” “\$1 myActivityId |
| failureAndRerunModus | Menjelaskan perilaku simpul konsumen ketika dependensi gagal atau menjalankan kembali. | Pencacahan |
| insertQuery | Sebuah pernyataan SQL untuk memasukkan data ke dalam tabel. | String |
| lateAfterTimeout | Waktu berlalu setelah alur mulai di mana objek harus menyelesaikan. Hal ini dipicu hanya ketika jenis jadwal tidak disetel ke ondemand. | Periode |
| maxActiveInstances | Jumlah maksimum instans aktif bersamaan dari suatu komponen. Re-runs tidak dihitung terhadap jumlah instans aktif. | Bilangan Bulat |
| maximumRetries | Jumlah maksimum percobaan ulang pada pelanggaran | Bilangan Bulat |
| onFail | Tindakan untuk dijalankan ketika objek saat ini gagal. | Objek Referensi, misalnya “onFail”: \$1"ref”:” “\$1 myActionId |
| onLateAction | Tindakan yang harus dipicu jika objek belum dijadwalkan atau masih belum selesai. | Objek Referensi, misalnya "onLateAction“: \$1" ref”:” myActionId “\$1 |
| onSuccess | Tindakan untuk dijalankan ketika objek saat ini berhasil. | Objek Referensi, misalnya “onSuccess”: \$1"ref”:” “\$1 myActionId |
| induk | Induk dari objek saat ini dari mana slot akan diwariskan. | Objek Referensi, misalnya “induk”: \$1"ref”:” myBaseObject Id "\$1 |
| pipelineLogUri | URI S3 (seperti 's3://BucketName/Key/ ') untuk mengunggah log untuk pipeline. | String |
| prasyarat | Mendefinisikan prasyarat secara opsional. Sebuah simpul data tidak ditandai "READY" sampai semua prasyarat telah terpenuhi. | Objek Referensi, misalnya “prasyarat”: \$1"ref”:” “myPreconditionId\$1 |
| reportProgressTimeout | Timeout untuk panggilan kerja jarak jauh berturut-turut ke reportProgress. Jika disetel, maka kegiatan jarak jauh yang tidak melaporkan kemajuan untuk jangka waktu tertentu dapat dianggap terhenti dan jadi dicoba lagi. | Periode |
| retryDelay | Durasi timeout antara dua upaya coba lagi. | Periode |
| runsOn | Sumber daya komputasi untuk menjalankan aktivitas atau perintah. Misalnya, instans Amazon EC2 atau klaster Amazon EMR. | Objek Referensi, misalnya “RunsOn”: \$1"ref”:” “\$1 myResourceId |
| scheduleType | Jenis jadwal mengizinkan Anda untuk menentukan apakah objek dalam definisi alur Anda harus dijadwalkan pada awal interval atau akhir interval. Penjadwalan Gaya Deret Waktu berarti instans dijadwalkan pada akhir setiap interval dan Penjadwalan Gaya Cron berarti intans dijadwalkan pada awal setiap interval. Jadwal sesuai permintaan mengizinkan Anda untuk menjalankan alur satu kali per aktivasi. Ini berarti Anda tidak perlu meng-klon atau membuat ulang alur untuk menjalankannya lagi. Jika Anda menggunakan jadwal sesuai permintaan itu harus ditentukan dalam objek default dan harus menjadi satu-satunya scheduleType yang ditentukan untuk objek dalam alur. Untuk menggunakan saluran pipa sesuai permintaan, Anda cukup memanggil ActivatePipeline operasi untuk setiap proses berikutnya. Nilai adalah: cron, ondemand, dan timeseries. | Pencacahan |
| schemaName | Nama skema yang memegang tabel | String |
| selectQuery | Sebuah pernyataan SQL untuk mengambil data dari tabel. | String |
| workerGroup | Kelompok pekerja. Ini digunakan untuk tugas perutean. Jika Anda memberikan nilai runsOn dan workerGroup ada, workerGroup diabaikan. | String |
****
| Bidang Runtime | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @activeInstances | Daftar objek instans aktif terjadwal saat ini. | Objek Referensi, misalnya “ActiveInstances”: \$1"ref”:” Id "\$1 myRunnableObject |
| @actualEndTime | Waktu ketika eksekusi objek ini selesai. | DateTime |
| @actualStartTime | Waktu ketika eksekusi objek ini dimulai. | DateTime |
| cancellationReason | cancellationReason jika objek ini dibatalkan. | String |
| @cascadeFailedOn | Deskripsi rantai dependensi tempat objek gagal. | Objek Referensi, misalnya "cascadeFailedOn“: \$1" ref”:” myRunnableObject Id "\$1 |
| emrStepLog | Log langkah EMR hanya tersedia pada upaya aktivitas EMR | String |
| errorId | errorId jika objek ini gagal. | String |
| errorMessage | errorMessage jika objek ini gagal. | String |
| errorStackTrace | Jejak tumpukan kesalahan jika objek ini gagal. | String |
| @finishedTime | Waktu saat objek ini menyelesaikan eksekusinya. | DateTime |
| hadoopJobLog | log tugas Hadoop tersedia pada upaya untuk kegiatan berbasis EMR. | String |
| @healthStatus | Status kondisi objek yang mencerminkan keberhasilan atau kegagalan instans objek terakhir yang mencapai keadaan dihentikan. | String |
| @healthStatusFromInstanceId | Id dari objek instans terakhir yang mencapai keadaan dihentikan. | String |
| @ healthStatusUpdated Waktu | Waktu di mana status kondisi diperbarui terakhir kali. | DateTime |
| hostname | Nama host klien yang mengambil upaya tugas. | String |
| @lastDeactivatedTime | Waktu di mana objek ini terakhir dinonaktifkan. | DateTime |
| @ latestCompletedRun Waktu | Waktu proses terakhir yang eksekusinya selesai. | DateTime |
| @latestRunTime | Waktu proses terakhir untuk eksekusi yang dijadwalkan. | DateTime |
| @nextRunTime | Waktu run yang akan dijadwalkan berikutnya. | DateTime |
| reportProgressTime | Waktu terbaru bahwa aktivitas jarak jauh melaporkan kemajuan. | DateTime |
| @scheduledEndTime | Jadwalkan waktu akhir untuk objek | DateTime |
| @scheduledStartTime | Jadwalkan waktu mulai untuk objek | DateTime |
| @status | Status objek ini. | String |
| @version | Versi alur objek dibuat dengan. | String |
| @waitingOn | Deskripsi daftar dependensi objek ini sedang menunggu. | Objek Referensi, misalnya “WaitingOn”: \$1"ref”:” Id "\$1 myRunnableObject |
****
| Bidang Sistem | Deskripsi | Jenis Slot |
| --- | --- | --- |
| @error | Galat mendeskripsikan obyek yang tidak terbentuk | String |
| @pipelineId | Id dari alur tempat objek ini berada | String |
| @sphere | Lingkup dari sebuah objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects yang mengeksekusi Attempt Objects | String |
## Lihat Juga
+ [S3 DataNode](dp-object-s3datanode.md)