WriteRows

id: bigtable_write_rows
namespace: company.team

inputs:
  - id: table_id
    type: STRING
    defaults: events

tasks:
  - id: write
    type: io.kestra.plugin.gcp.bigtable.WriteRows
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    instanceId: my-instance
    tableId: "{{ inputs.table_id }}"
    columnFamily: cf1
    rows:
      - rowKey: "row-001"
        cells:
          value: "42"

  - id: log
    type: io.kestra.plugin.core.log.Log
    message: "Written {{ outputs.write.rowCount }} rows to {{ inputs.table_id }}"

id: bigtable_write_rows_with_delete
namespace: company.team

tasks:
  - id: write
    type: io.kestra.plugin.gcp.bigtable.WriteRows
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    instanceId: my-instance
    tableId: events
    columnFamily: cf1
    rows:
      - rowKey: "row-001"
        cells:
          status: "processed"
        deleteCells:
          - stale_flag