Streams data into BigQuery one record at a time without needing to run a load job. Requires the WRITER dataset role.
Arguments
Parameters | |
---|---|
datasetId |
Required. Dataset ID of the destination table.
|
projectId |
Required. Project ID of the destination table.
|
tableId |
Required. Table ID of the destination table.
|
body |
Required.
|
Raised exceptions
Exceptions | |
---|---|
ConnectionError |
In case of a network problem (such as DNS failure or refused connection). |
HttpError |
If the response status is >= 400 (excluding 429 and 503). |
TimeoutError |
If a long-running operation takes longer to finish than the specified timeout limit. |
TypeError |
If an operation or function receives an argument of the wrong type. |
ValueError |
If an operation or function receives an argument of the right type but an inappropriate value. For example, a negative timeout. |
Response
If successful, the response contains an instance of TableDataInsertAllResponse
.
Subworkflow snippet
Some fields might be optional or required. To identify required fields, refer to the API documentation.
YAML
- insertAll: call: googleapis.bigquery.v2.tabledata.insertAll args: datasetId: ... projectId: ... tableId: ... body: ignoreUnknownValues: ... kind: ... rows: insertId: ... json: ... skipInvalidRows: ... templateSuffix: ... result: insertAllResult
JSON
[ { "insertAll": { "call": "googleapis.bigquery.v2.tabledata.insertAll", "args": { "datasetId": "...", "projectId": "...", "tableId": "...", "body": { "ignoreUnknownValues": "...", "kind": "...", "rows": { "insertId": "...", "json": "..." }, "skipInvalidRows": "...", "templateSuffix": "..." } }, "result": "insertAllResult" } } ]