Platform For AI:CreatePipeline

Exemplo de definição de fluxo de trabalho: este fluxo de trabalho consiste em ler uma tabela de dados (data_source) e realizar a conversão de tipo (type_transform).

apiVersion: "core/v1"
metadata:
  provider: "166233998075****"
  version: "v1"
  identifier: "my_pipeline"
  name: "source-transform"
spec:
  inputs:
    parameters:
    - name: "execution_maxcompute"
      value:
        spec:
          endpoint: "http://service.cn.maxcompute.aliyun-inc.com/api"
          odpsProject: "test_i****"
      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: "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"

As configurações dos parâmetros principais são as seguintes:

• provider: Substitua o valor pelo ID da sua conta.

• odpsProject: Substitua o valor pelo nome do recurso do MaxCompute vinculado ao workspace. Para obter informações sobre como consultar o nome do recurso do MaxCompute, consulte Manage workspaces.