Cria uma tarefa de workflow.
Experimente agora
Testar
Autorização RAM
Sintaxe da solicitação
POST /api/v1/pipelineruns HTTP/1.1
Parâmetros da solicitação
|
Parâmetro |
Tipo |
Obrigatório |
Descrição |
Exemplo |
| body |
object |
Não |
A tarefa de workflow. |
|
| PipelineId |
string |
Não |
O ID do workflow. Você deve especificar PipelineId ou PipelineManifest. |
flow-rer7y*** |
| Name |
string |
Não |
O nome da tarefa de workflow. Se você deixar este parâmetro vazio, um nome será gerado automaticamente. |
testName |
| PipelineManifest |
string |
Não |
A definição do workflow. Para ver um exemplo, consulte a descrição complementar dos parâmetros de solicitação abaixo. Você deve especificar PipelineId ou 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: "Read data table-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: "Type transform-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 |
Não |
Os argumentos. |
arguments: parameters: - name: "execution_maxcompute" value: endpoint: "http://service***" odpsProject: "pai***" |
| NoConfirmRequired |
boolean |
Não |
Especifica se a execução do pipeline deve ser iniciada diretamente. Valores válidos:
|
true |
| WorkspaceId |
string |
Sim |
O ID do workspace. |
84*** |
| SourceType |
string |
Não |
O tipo de origem da tarefa de workflow. Valores válidos:
|
UNKNOWN |
| SourceId |
string |
Não |
O ID da origem. |
experiment-ybpy*** |
| Options |
string |
Não |
As opções para criar a tarefa de workflow. O valor deve estar no formato JSON. |
{"mlflow":{"experimentId":"exp-1jdk***"}} |
| Accessibility |
string |
Não |
A visibilidade do workflow. Valores válidos:
|
PUBLIC |
Exemplo de definição de workflow: este workflow consiste na leitura de uma tabela de dados (data_source) e na conversão de tipo (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: "Read data table-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: "Type conversion-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"
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
A estrutura da resposta. |
||
| RequestId |
string |
O ID da solicitação. |
DA869D1B-035A-43B2-ACC1-C56681BD9FAA |
| PipelineRunId |
string |
O ID da tarefa de workflow. |
flow-rbvg*** |
Exemplos
Resposta de sucesso
JSON formato
{
"RequestId": "DA869D1B-035A-43B2-ACC1-C56681BD9FAA",
"PipelineRunId": "flow-rbvg***"
}
Códigos de erro
Consulte Códigos de Erro para uma lista completa.
Notas de versão
Consulte Notas de Versão para uma lista completa.