All Products
Search

This Product

    E-MapReduce:CreateProcessDefinitionWithSchedule

    Document Center

    E-MapReduce:CreateProcessDefinitionWithSchedule

    Last Updated:Jun 11, 2026

    Membuat definisi alur kerja.

    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:CreateProcessDefinitionWithSchedule

    none

    *All Resource

    *

    		 None None

    Sintaks permintaan

    POST /dolphinscheduler/projects/{bizId}/process-definition HTTP/1.1

    Path Parameters

    Parameter

    Type

    Required

    Description

    Example
    bizId

    string

    Yes

    ID ruang kerja.

    w-d8********

    Parameter permintaan

    Parameter

    Type

    Required

    Description

    Example
    productNamespace

    string

    Yes

    Kode produk.

    SS
    name

    string

    Yes

    Nama alur kerja.

    ods_batch_workflow
    description

    string

    Yes

    Deskripsi alur kerja.

    ods batch workflow
    timeout

    integer

    No

    Periode batas waktu default untuk eksekusi alur kerja.

    60
    taskRelationJson

    array<object>

    Yes

    Array JSON dari dependensi tugas. `preTaskCode` menentukan ID tugas hulu dan `postTaskCode` menentukan ID tugas hilir. Setiap tugas harus memiliki ID unik. Untuk tugas tanpa dependensi hulu, atur `preTaskCode` ke 0.

    object

    Yes

    Array JSON dari dependensi tugas. `preTaskCode` menentukan ID tugas hulu dan `postTaskCode` menentukan ID tugas hilir. Setiap tugas harus memiliki ID unik. Untuk tugas tanpa dependensi hulu, atur `preTaskCode` ke 0.

    name

    string

    Yes

    Nama topologi tugas. Gunakan 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.

    28************
    postTaskVersion

    integer

    Yes

    Versi tugas hilir.

    1
    taskDefinitionJson

    array<object>

    Yes

    Array JSON dari definisi tugas. Array ini berisi detail untuk semua tugas dalam alur kerja.

    array<object>

    Yes

    Objek JSON yang mendefinisikan tugas. Objek ini berisi detail untuk tugas tersebut.

    code

    integer

    Yes

    ID definisi tugas.

    36************
    description

    string

    No

    Deskripsi definisi tugas.

    ods transform task
    alertEmailAddress

    string

    No

    Alamat email tujuan pengiriman peringatan.

    foo_bar@spark.alert.invalid.com
    startAlertEnable

    boolean

    No

    Menentukan apakah akan mengaktifkan peringatan saat tugas dimulai.

    false
    failAlertEnable

    boolean

    No

    Menentukan apakah akan mengaktifkan peringatan saat tugas gagal.

    false
    failRetryTimes

    integer

    No

    Jumlah percobaan ulang tugas setelah gagal.

    1
    name

    string

    Yes

    Nama tugas.

    ods_transform_task
    taskParams

    object

    Yes

    Parameter dari definisi tugas.

    workspaceBizId

    string

    Yes

    ID ruang kerja.

    w-d8********
    taskBizId

    string

    Yes

    ID tugas Data Development.

    TSK-d87******************
    resourceQueueId

    string

    Yes

    Antrian sumber daya tempat tugas Spark dijalankan.

    root_queue
    sparkDriverCores

    integer

    No

    Jumlah core untuk Spark driver.

    1
    sparkExecutorCores

    integer

    No

    Jumlah core untuk setiap Spark executor.

    1
    sparkDriverMemory

    integer

    No

    Memori Spark driver.

    4g
    sparkExecutorMemory

    integer

    No

    Memori setiap Spark executor.

    4g
    sparkConf

    array<object>

    No

    Konfigurasi tugas Spark.

    object

    No

    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 mesin Spark.

    esr-4.0.0 (Spark 3.5.2, Scala 2.12)
    sparkLogLevel

    string

    No

    Tingkat log untuk Spark.

    INFO
    sparkLogPath

    string

    No

    Path tempat log tugas Spark disimpan.

    oss://data***/spark/logs
    displaySparkVersion

    string

    No

    Versi tampilan mesin Spark.

    esr-4.0.0 (Spark 3.5.2, Scala 2.12)
    fusion

    boolean

    No

    Menentukan apakah akan mengaktifkan mesin Fusion untuk akselerasi.

    false
    environmentId

    string

    No

    ID lingkungan.

    env-crhq2h5lhtgju93buhkg
    type

    string

    No

    Tipe tugas Spark.

    SQL
    localParams

    array<object>

    No

    object

    No

    prop

    string

    No

    direct

    string

    No

    type

    string

    No

    value

    string

    No

    taskType

    string

    Yes

    Tipe node alur kerja.

    EMR_SERVERLESS_SPARK
    timeout

    integer

    No

    Periode batas waktu untuk metode callback, dalam detik.

    1200
    tags

    object

    No

    Tag.

    string

    No

    String JSON dari pasangan kunci-nilai tag.

    “{\"tagkey\":\"tagvalue\"}”
    executionType

    string

    Yes

    Kebijakan eksekusi.

    PARALLEL
    alertEmailAddress

    string

    No

    Alamat email tujuan pengiriman peringatan.

    foo_bar@spark.alert.invalid.com
    schedule

    object

    No

    Konfigurasi penjadwalan.

    startTime

    string

    No

    Waktu mulai jadwal.

    2024-12-23 16:13:27
    endTime

    string

    No

    Waktu berakhir jadwal.

    2025-12-23 16:13:27
    crontab

    string

    No

    Ekspresi cron untuk jadwal.

    0 0 0 * * ?
    timezoneId

    string

    No

    ID zona waktu.

    Asia/Shanghai
    retryTimes

    integer

    No

    Jumlah percobaan ulang.

    1
    taskParallelism

    integer

    No

    Tingkat paralelisme untuk tugas.

    1
    resourceQueue

    string

    No

    Antrian sumber daya.

    root_queue
    tags

    object

    No

    Tag.

    string

    No

    String JSON dari pasangan kunci-nilai tag.

    “{\"tagkey\":\"tagvalue\"}”
    publish

    boolean

    No

    Menentukan apakah akan mempublikasikan alur kerja.

    true
    regionId

    string

    No

    ID region.

    cn-hangzhou
    runAs

    string

    No

    UID Alibaba Cloud pengguna yang menjalankan alur kerja.

    113***************
    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 API.

    1400009
    msg

    string

    Pesan terperinci untuk kode pengembalian.

    No permission for resource action
    success

    string

    Menunjukkan apakah permintaan berhasil.

    true
    failed

    string

    Menunjukkan apakah permintaan gagal.

    false
    data

    object

    Data yang dikembalikan.

    id

    integer

    Nomor seri definisi alur kerja.

    12342
    code

    integer

    ID definisi alur kerja.

    160************
    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": 12342,
    "code": 0
  },
  "httpStatusCode": 200
}

    Kode kesalahan

    Lihat Error Codes untuk daftar lengkap.

    Catatan rilis

    Lihat Release Notes untuk daftar lengkap.