Membuat tugas pipeline.
Coba sekarang
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
paiflow:CreatePipelineRun |
create |
*All Resource
|
None | None |
Sintaks permintaan
POST /api/v1/pipelineruns HTTP/1.1
Parameter permintaan
|
Parameter |
Type |
Required |
Description |
Example |
| body |
object |
No |
Tugas pipeline. |
|
| PipelineId |
string |
No |
ID pipeline. Anda harus mengonfigurasi PipelineId atau PipelineManifest. |
flow-rer7y*** |
| Name |
string |
No |
Nama tugas pipeline. Jika Anda mengosongkan parameter ini, sistem akan secara otomatis menghasilkan nama. |
testName |
| PipelineManifest |
string |
No |
Definisi pipeline. Untuk informasi lebih lanjut, lihat contoh definisi pipeline. Anda harus mengonfigurasi PipelineId atau PipelineManifest. |
apiVersion: "core/v1"\nmetadata:\n provider: "1557702098******"\n version: "v1"\n identifier: "my_pipeline"\n name: "source-transform"\nspec:\n inputs:\n parameters:\n - name: "execution_maxcompute"\n type: "Map"\n pipelines:\n - apiVersion: "core/v1"\n metadata:\n provider: "pai"\n version: "v1"\n identifier: "data_source"\n name: "data_source"\n displayName: "读数据表-1"\n spec:\n arguments:\n parameters:\n - name: "inputTableName"\n value: "pai_online_project.wumai_data"\n - name: "partition"\n value: "20220101"\n - name: "execution"\n from: "{{inputs.parameters.execution_maxcompute}}"\n - apiVersion: "core/v1"\n metadata:\n provider: "pai"\n version: "v1"\n identifier: "type_transform"\n name: "type_transform"\n displayName: "类型转换-1"\n spec:\n arguments:\n artifacts:\n - name: "inputTable"\n from: "{{pipelines.data_source.outputs.artifacts.outputTable}}"\n parameters:\n - name: "cols_to_double"\n value: "time,hour,pm2,pm10,so2,co,no2"\n - name: "execution"\n from: "{{inputs.parameters.execution_maxcompute}}"\n dependencies:\n - "data_source" |
| Arguments |
string |
No |
Parameter. |
arguments: parameters: - name: "execution_maxcompute" value: endpoint: "http://service***" odpsProject: "pai***" |
| NoConfirmRequired |
boolean |
No |
Menentukan apakah akan memulai tugas pipeline. Nilai yang valid:
|
true |
| WorkspaceId |
string |
Yes |
ID ruang kerja. |
84*** |
| SourceType |
string |
No |
Jenis sumber tugas pipeline. Nilai yang valid:
|
UNKNOWN |
| SourceId |
string |
No |
ID sumber. |
experiment-ybpy*** |
| Options |
string |
No |
Opsi yang digunakan untuk membuat tugas pipeline, dalam format JSON. |
{"mlflow":{"experimentId":"exp-1jdk***"}} |
| Accessibility |
string |
No |
Aksesibilitas pipeline.
|
PUBLIC |
Contoh definisi pipeline: Pipeline terdiri dari node baca tabel data_source dan node konversi tipe data type_transform.
apiVersion: "core/v1"
metadata:
provider: "1557702098******"
version: "v1"
identifier: "my_pipeline"
name: "source-transform"
spec:
inputs:
parameters:
- name: "execution_maxcompute"
type: "Map"
pipelines:
- apiVersion: "core/v1"
metadata:
provider: "pai"
version: "v1"
identifier: "data_source"
name: "data_source"
displayName: "Baca-Tabel-1"
spec:
arguments:
parameters:
- name: "inputTableName"
value: "pai_online_project.wumai_data"
- name: "partition"
value: "20220101"
- name: "execution"
from: "{{inputs.parameters.execution_maxcompute}}"
- apiVersion: "core/v1"
metadata:
provider: "pai"
version: "v1"
identifier: "type_transform"
name: "type_transform"
displayName: "Konversi-Tipe-Data-1"
spec:
arguments:
artifacts:
- name: "inputTable"
from: "{{pipelines.data_source.outputs.artifacts.outputTable}}"
parameters:
- name: "cols_to_double"
value: "time,hour,pm2,pm10,so2,co,no2"
- name: "execution"
from: "{{inputs.parameters.execution_maxcompute}}"
dependencies:
- "data_source"
Elemen respons
|
Element |
Type |
Description |
Example |
|
object |
Parameter respons. |
||
| RequestId |
string |
ID permintaan. |
DA869D1B-035A-43B2-ACC1-C56681BD9FAA |
| PipelineRunId |
string |
ID tugas pipeline. |
flow-rbvg*** |
Contoh
Respons sukses
JSONformat
{
"RequestId": "DA869D1B-035A-43B2-ACC1-C56681BD9FAA",
"PipelineRunId": "flow-rbvg***"
}
Kode kesalahan
Lihat Error Codes untuk daftar lengkap.
Catatan rilis
Lihat Release Notes untuk daftar lengkap.