insert2.workflows.yaml

# long run insert with parameter
main:
  params: [args]
  steps:
    - init:
        assign:
        - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
        - dataset_id: "ds201"
        - table_id: "mobilelog2"
    - prepareInsert:
        switch:
          - condition: ${args.key1 == 1}
            next: insert1
          - condition: ${args.key1 == 2}
            next: insert2
          - condition: ${args.key1 == 3}
            next: insert3
    - insert1:
        call: googleapis.bigquery.v2.jobs.insert
        args:
          projectId: ${project_id}
          body:
            configuration:
              query:
                query: "INSERT INTO cliu201.ds201.mobilelog2 (id, price, product) VALUES  ('1','1','1')"
                allowLargeResults: true
                useLegacySql: false
        next: end

    - insert2:
        call: googleapis.bigquery.v2.jobs.insert
        args:
          projectId: ${project_id}
          body:
            configuration:
              query:
                query: "INSERT INTO cliu201.ds201.mobilelog2 (id, price, product) VALUES  ('2','2','2')"
                allowLargeResults: true
                useLegacySql: false
        next: end

    - insert3:
        call: googleapis.bigquery.v2.jobs.insert
        args:
          projectId: ${project_id}
          body:
            configuration:
              query:
                query: "INSERT INTO cliu201.ds201.mobilelog2 (id, price, product) VALUES  ('3','3','3')"
                allowLargeResults: true
                useLegacySql: false
        next: end