WriteRows

WriteRows
Certified
Write rows to a Google Cloud Bigtable table

yaml
type: io.kestra.plugin.gcp.bigtable.WriteRows

Examples

yaml
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 }}"

yaml
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

Properties

instanceId *string

projectId *string

rows *array

Definitions

io.kestra.plugin.gcp.bigtable.WriteRows-RowInput

rowKey*string

cellsobject

SubTypestring

columnFamilystring

deleteCellsarray

SubTypestring

tableId *string

columnFamily string

emulatorHost string

impersonatedServiceAccount string

scopes array

SubTypestring

serviceAccount string

Outputs

rowCount integer

Metrics

rows.written counter

Unitrows

Docker

Docker tasks for building images, running containers, and managing artifacts from Kestra workflows.

CoreInfrastructure

CloudQuery

Tasks that run CloudQuery commands to sync data through the CLI.

Data

WriteRowsCertifiedWrite rows to a Google Cloud Bigtable table

More Plugins in this Category

Docker

CloudQuery

WriteRows
Certified
Write rows to a Google Cloud Bigtable table