All Products
Search
Document Center

E-MapReduce:UpdateProcessDefinitionWithSchedule

Last Updated:Jun 11, 2026

Memperbarui definisi alur kerja dan penjadwalan waktunya.

Coba sekarang

Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

Test

RAM authorization

Tabel berikut menjelaskan otorisasi yang diperlukan untuk memanggil API ini. Anda dapat menentukannya dalam kebijakan Resource Access Management (RAM). Kolom pada tabel dijelaskan sebagai berikut:

  • Action: Aksi yang dapat digunakan dalam elemen Action pada pernyataan kebijakan izin RAM untuk memberikan izin guna melakukan operasi tersebut.

  • API: API yang dapat Anda panggil untuk melakukan aksi tersebut.

  • Access level: Tingkat akses yang telah ditentukan untuk setiap API. Nilai yang valid: create, list, get, update, dan delete.

  • Resource type: Jenis resource yang mendukung otorisasi untuk melakukan aksi tersebut. Ini menunjukkan apakah aksi tersebut mendukung izin tingkat resource. Resource yang ditentukan harus kompatibel dengan aksi tersebut. Jika tidak, kebijakan tersebut tidak akan berlaku.

    • Untuk API dengan izin tingkat resource, jenis resource yang diperlukan ditandai dengan tanda bintang (*). Tentukan Nama Sumber Daya Alibaba Cloud (ARN) yang sesuai dalam elemen Resource pada kebijakan.

    • Untuk API tanpa izin tingkat resource, ditampilkan sebagai All Resources. Gunakan tanda bintang (*) dalam elemen Resource pada kebijakan.

  • Condition key: Kunci kondisi yang didefinisikan oleh layanan. Kunci ini memungkinkan kontrol granular, berlaku baik hanya untuk aksi maupun untuk aksi yang terkait dengan resource tertentu. Selain kunci kondisi spesifik layanan, Alibaba Cloud menyediakan serangkaian common condition keys yang berlaku di semua layanan yang didukung RAM.

  • Dependent action: Aksi dependen yang diperlukan untuk menjalankan aksi tersebut. Untuk menyelesaikan aksi tersebut, pengguna RAM atau role RAM harus memiliki izin untuk melakukan semua aksi dependen.

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.