Memperbarui definisi alur kerja dan penjadwalan waktunya.
Coba sekarang
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
emr-serverless-spark:UpdateProcessDefinitionWithSchedule |
none |
*All Resource
|
None | None |
Sintaks permintaan
PUT /dolphinscheduler/projects/{bizId}/process-definition/{code} HTTP/1.1
Path Parameters
|
Parameter |
Type |
Required |
Description |
Example |
| bizId |
string |
Yes |
ID ruang kerja. |
w-d8******** |
| code |
integer |
Yes |
ID definisi alur kerja. |
12************ |
Parameter permintaan
|
Parameter |
Type |
Required |
Description |
Example |
| productNamespace |
string |
Yes |
Kode produk. |
SS |
| name |
string |
Yes |
Nama alur kerja. |
ods_batch_workflow |
| description |
string |
No |
Deskripsi alur kerja. |
ods batch workflow |
| timeout |
integer |
No |
Periode batas waktu default untuk eksekusi alur kerja. |
300 |
| taskDefinitionJson |
array<object> |
Yes |
Array JSON dari definisi tugas. Array ini berisi informasi deskriptif untuk semua tugas dalam alur kerja. |
|
|
array<object> |
Yes |
Objek JSON untuk definisi tugas. Objek ini berisi informasi deskriptif untuk sebuah tugas dalam alur kerja. |
||
| code |
integer |
Yes |
ID definisi tugas. |
23************ |
| description |
string |
No |
Deskripsi definisi tugas. |
ods transform task |
| alertEmailAddress |
string |
No |
Alamat email untuk peringatan. |
foo_bar@spark.alert.invalid.com |
| startAlertEnable |
boolean |
No |
Menentukan apakah akan mengaktifkan peringatan ketika tugas dimulai. |
true |
| failAlertEnable |
boolean |
No |
Menentukan apakah akan mengaktifkan peringatan ketika tugas gagal. |
true |
| failRetryTimes |
integer |
No |
Jumlah percobaan ulang tugas jika gagal. |
1 |
| name |
string |
Yes |
Nama tugas. |
ods_transform_task |
| taskParams |
object |
Yes |
Parameter untuk definisi tugas. |
|
| workspaceBizId |
string |
Yes |
ID ruang kerja. |
w-d8******** |
| taskBizId |
string |
Yes |
ID tugas Pengembangan Data. |
TSK-d87****************** |
| resourceQueueId |
string |
Yes |
Nama antrian tempat tugas berjalan. |
root_queue |
| sparkDriverCores |
integer |
No |
Jumlah core untuk driver Spark. |
1 |
| sparkExecutorCores |
integer |
No |
Jumlah core untuk setiap executor Spark. |
1 |
| sparkDriverMemory |
integer |
No |
Ukuran memori driver Spark. |
4g |
| sparkExecutorMemory |
integer |
No |
Ukuran memori setiap executor Spark. |
4g |
| sparkConf |
array<object> |
No |
Konfigurasi tugas Spark. |
|
|
object |
No |
Konfigurasi tugas Spark. |
||
| key |
string |
No |
The key of the Spark configuration. |
spark.dynamicAllocation.enabled |
| value |
string |
No |
The value of the Spark configuration. |
true |
| sparkVersion |
string |
No |
Versi engine Spark. |
esr-4.0.0 (Spark 3.5.2, Scala 2.12) |
| sparkLogLevel |
string |
No |
Tingkat log Spark. |
INFO |
| sparkLogPath |
string |
No |
Path untuk menyimpan log tugas Spark. |
oss://data***/spark/logs |
| displaySparkVersion |
string |
No |
Versi tampilan engine Spark. |
esr-4.0.0 (Spark 3.5.2, Scala 2.12) |
| fusion |
boolean |
No |
Menentukan apakah akan mengaktifkan engine Fusion untuk akselerasi. |
false |
| environmentId |
string |
No |
ID lingkungan. |
ev-h************* |
| type |
string |
No |
Jenis job Spark. |
SQL |
| localParams |
array<object> |
No |
||
|
object |
No |
|||
| prop |
string |
No |
||
| direct |
string |
No |
||
| type |
string |
No |
||
| value |
string |
No |
||
| taskType |
string |
Yes |
Jenis node alur kerja. |
EMR-SERVERLESS-SPARK |
| timeout |
integer |
No |
Periode batas waktu default untuk eksekusi tugas. |
30 |
| tags |
object |
No |
Tag. |
|
|
string |
No |
String JSON dari pasangan key-value tag. |
“{\"tagkey\":\"tagvalue\"}” |
|
| taskRelationJson |
array<object> |
Yes |
Array JSON yang mendefinisikan dependensi antar tugas dalam alur kerja. `preTaskCode` menentukan ID tugas hulu, dan `postTaskCode` menentukan ID tugas hilir. Setiap tugas harus memiliki ID yang unik. Untuk node tugas tanpa tugas hulu, tambahkan dependensi dan atur `preTaskCode` ke 0. |
|
|
object |
Yes |
Objek JSON yang mendefinisikan dependensi tugas. `preTaskCode` menentukan ID tugas hulu, dan `postTaskCode` menentukan ID tugas hilir. Setiap tugas harus memiliki ID yang unik. Untuk node tugas tanpa tugas hulu, tambahkan dependensi dan atur `preTaskCode` ke 0. |
||
| name |
string |
Yes |
Nama topologi tugas. Anda dapat menggunakan nama alur kerja. |
ods batch workflow |
| preTaskCode |
integer |
Yes |
ID tugas hulu. |
16************ |
| preTaskVersion |
integer |
Yes |
Versi tugas hulu. |
1 |
| postTaskCode |
integer |
Yes |
ID tugas hilir. |
19************ |
| postTaskVersion |
integer |
Yes |
Versi tugas hilir. |
1 |
| executionType |
string |
Yes |
Kebijakan eksekusi. |
PARALLEL |
| alertEmailAddress |
string |
No |
Alamat email untuk peringatan. |
foo_bar@spark.alert.invalid.com |
| schedule |
object |
No |
Konfigurasi penjadwalan. |
|
| startTime |
string |
No |
Waktu mulai. |
2024-12-23 16:13:27 |
| endTime |
string |
No |
Waktu akhir jadwal. |
2025-12-23 16:13:27 |
| crontab |
string |
No |
Ekspresi cron untuk penjadwalan. |
0 0 0 * * ? |
| timezoneId |
string |
No |
ID zona waktu. |
Asia/Shanghai |
| retryTimes |
integer |
No |
Jumlah percobaan ulang. |
1 |
| taskParallelism |
integer |
No |
Tingkat eksekusi bersamaan untuk node alur kerja. |
1 |
| tags |
object |
No |
Tag. |
|
|
string |
No |
String JSON dari pasangan key-value tag. |
“{\"tagkey\":\"tagvalue\"}” |
|
| resourceQueue |
string |
No |
Antrian sumber daya. |
root_queue |
| releaseState |
string |
No |
Status rilis alur kerja. |
ONLINE |
| runAs |
string |
No |
Pengguna untuk menjalankan alur kerja. |
113*************** |
| publish |
boolean |
No |
Menentukan apakah akan mempublikasikan alur kerja. |
true |
| regionId |
string |
No |
ID region. |
cn-hangzhou |
| globalParams |
array<object> |
No |
||
|
object |
No |
|||
| prop |
string |
No |
||
| value |
string |
No |
||
| direct |
string |
No |
||
| type |
string |
No |
Elemen respons
|
Element |
Type |
Description |
Example |
|
object |
Skema Respons |
||
| requestId |
string |
ID permintaan. |
DD6B1B2A-5837-5237-ABE4-FF0C8944**** |
| code |
integer |
Kode pengembalian dari API backend. |
1400009 |
| msg |
string |
Deskripsi rinci yang sesuai dengan kode pengembalian. |
No permission for resource action |
| success |
string |
Menunjukkan apakah permintaan berhasil. |
true |
| failed |
string |
Jumlah operasi yang gagal. |
false |
| data |
object |
Data yang dikembalikan. |
|
| id |
string |
Nomor definisi alur kerja. |
123223 |
| code |
string |
ID definisi alur kerja. |
12*********** |
| name |
string |
Nama definisi alur kerja. |
ods_batch_workflow |
| version |
integer |
Nomor versi. |
1 |
| releaseState |
string |
Status rilis alur kerja. |
ONLINE |
| bizId |
string |
ID ruang kerja. |
alicloud_ack_one_cluster |
| description |
string |
Deskripsi definisi alur kerja. |
1 |
| createTime |
string |
Waktu ketika definisi alur kerja dibuat. |
2024-09-05T02:03:19Z |
| updateTime |
string |
Waktu ketika definisi alur kerja diperbarui. |
2024-03-05T06:24:27Z |
| userId |
string |
ID pengguna yang menjadwalkan alur kerja. |
113********* |
| userName |
string |
Nama pengguna yang menjadwalkan alur kerja. |
w-******** |
| projectName |
string |
Nama proyek tempat alur kerja berada. |
w-******** |
| executionType |
string |
Kebijakan eksekusi. |
SERIAL |
| alertEmailAddress |
string |
Alamat email untuk peringatan. |
foo_bar@spark.alert.invalid.com |
| startTime |
string |
Waktu mulai jadwal. |
0 |
| endTime |
string |
Waktu akhir jadwal. |
1710432000000 |
| timezoneId |
string |
ID zona waktu. |
Asia/Shanghai |
| crontab |
string |
Ekspresi cron untuk penjadwalan. |
0 0 0 * * ? |
| versionHashCode |
string |
Hash code dari versi. |
dwerf********* |
| httpStatusCode |
integer |
Kode status HTTP. |
200 |
Contoh
Respons sukses
JSONformat
{
"requestId": "DD6B1B2A-5837-5237-ABE4-FF0C8944****",
"code": 1400009,
"msg": "No permission for resource action",
"success": "true",
"failed": "false",
"data": {
"id": "123223",
"code": "12***********",
"name": "ods_batch_workflow",
"version": 1,
"releaseState": "ONLINE",
"bizId": "alicloud_ack_one_cluster",
"description": "1",
"createTime": "2024-09-05T02:03:19Z",
"updateTime": "2024-03-05T06:24:27Z",
"userId": "113*********",
"userName": "w-********",
"projectName": "w-********",
"executionType": "SERIAL",
"alertEmailAddress": "foo_bar@spark.alert.invalid.com\n",
"startTime": "0",
"endTime": "1710432000000",
"timezoneId": "Asia/Shanghai\n",
"crontab": "0 0 0 * * ?\n",
"versionHashCode": "dwerf*********"
},
"httpStatusCode": 200
}
Kode kesalahan
Lihat Error Codes untuk daftar lengkap.
Catatan rilis
Lihat Release Notes untuk daftar lengkap.