Platform For AI:UpdatePipeline

Definisi pipeline contoh: Pipeline terdiri dari node baca tabel data_source dan node konversi tipe data 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 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: "Data 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".

Konfigurasi parameter utama dalam definisi pipeline contoh:

• provider: Ganti nilai parameter ini dengan ID akun Anda.

• odpsProject: Ganti nilai parameter ini dengan nama resource MaxCompute yang terkait dengan workspace. Untuk informasi selengkapnya tentang cara mengkueri nama resource MaxCompute, lihat Manage workspaces.