Google Cloud StorageWrite
CertifiedStream a file to BigQuery via Storage Write API
Google Cloud StorageWrite
Stream a file to BigQuery via Storage Write API
Reads a file from Kestra internal storage and writes rows with the BigQuery Storage Write API. Supports DEFAULT, COMMITTED, or PENDING streams (commit required for PENDING). Requires the destination table to exist.
type: io.kestra.plugin.gcp.bigquery.StorageWriteExamples
id: gcp_bq_storage_write
namespace: company.team
tasks:
- id: read_data
type: io.kestra.plugin.core.http.Download
uri: https://dummyjson.com/products/1
- id: storage_write
type: io.kestra.plugin.gcp.bigquery.StorageWrite
from: "{{ outputs.read_data.uri }}"
destinationTable: "my-project.my_dataset.my_table"
writeStreamType: DEFAULT
Properties
destinationTable *Requiredstring
The table where to load data
The table must be created before.
bufferSize integerstring
1000The number of records to send on each query
from string
The fully-qualified URIs that point to source data
impersonatedServiceAccount string
The GCP service account to impersonate
location string
The geographic location where the dataset should reside
This property is experimental and might be subject to change or removed.
See Dataset Location
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
projectId string
The GCP project ID
scopes array
["https://www.googleapis.com/auth/cloud-platform"]The GCP scopes to be used
serviceAccount string
The GCP service account
writeStreamType string
DEFAULTDEFAULTCOMMITTEDPENDINGThe type of write stream to use
Outputs
commitTime string
date-timeCommit time reported by BigQuery, only on PENDING writeStreamType
rows integer
Rows count
rowsCount integer
Rows count reported by BigQuery, only on PENDING writeStreamType
Metrics
rows counter
Rows count.
rows_count counter
Rows count reported by BigQuery, only on PENDING writeStreamType.
