Google BigQuery
Read and write data to Google BigQuery.
Authentication
This connector uses OAuth 2.0 authentication.
info
Set up your connection in the Abstra Console before using it in your workflows.
How to use
Using the Smart Chat
Execute the action "CHOOSE_ONE_ACTION_BELOW" from my connector "YOUR_CONNECTOR_NAME" using the params "PARAMS_HERE".
Using the Web Editor
from abstra.connectors import run_connection_action
result = run_connection_action(
connection_name="your_connection_name",
action_name="your_action_name",
params={
"param1": "value1",
"param2": "value2"
})
Available Actions
This connector provides 47 actions:
| Action | Parameters |
|---|---|
| datasets_delete | No parameters |
| datasets_get | No parameters |
| datasets_insert | access (array) creationTime (string) datasetReference (undefined) defaultCollation (string) defaultEncryptionConfiguration (undefined) defaultPartitionExpirationMs (string) defaultRoundingMode (string) defaultTableExpirationMs (string) description (string) etag (string) externalCatalogDatasetOptions (undefined) externalDatasetReference (undefined) friendlyName (string) id (string) isCaseInsensitive (boolean) kind (string) labels (object) lastModifiedTime (string) linkedDatasetMetadata (undefined) linkedDatasetSource (undefined) location (string) maxTimeTravelHours (string) resourceTags (object) restrictions (undefined) satisfiesPzi (boolean) satisfiesPzs (boolean) selfLink (string) storageBillingModel (string) tags (array) type (string) |
| datasets_list | No parameters |
| datasets_patch | access (array) creationTime (string) datasetReference (undefined) defaultCollation (string) defaultEncryptionConfiguration (undefined) defaultPartitionExpirationMs (string) defaultRoundingMode (string) defaultTableExpirationMs (string) description (string) etag (string) externalCatalogDatasetOptions (undefined) externalDatasetReference (undefined) friendlyName (string) id (string) isCaseInsensitive (boolean) kind (string) labels (object) lastModifiedTime (string) linkedDatasetMetadata (undefined) linkedDatasetSource (undefined) location (string) maxTimeTravelHours (string) resourceTags (object) restrictions (undefined) satisfiesPzi (boolean) satisfiesPzs (boolean) selfLink (string) storageBillingModel (string) tags (array) type (string) |
| datasets_undelete | deletionTime (string) |
| datasets_update | access (array) creationTime (string) datasetReference (undefined) defaultCollation (string) defaultEncryptionConfiguration (undefined) defaultPartitionExpirationMs (string) defaultRoundingMode (string) defaultTableExpirationMs (string) description (string) etag (string) externalCatalogDatasetOptions (undefined) externalDatasetReference (undefined) friendlyName (string) id (string) isCaseInsensitive (boolean) kind (string) labels (object) lastModifiedTime (string) linkedDatasetMetadata (undefined) linkedDatasetSource (undefined) location (string) maxTimeTravelHours (string) resourceTags (object) restrictions (undefined) satisfiesPzi (boolean) satisfiesPzs (boolean) selfLink (string) storageBillingModel (string) tags (array) type (string) |
| jobs_cancel | No parameters |
| jobs_delete | No parameters |
| jobs_get | No parameters |
| jobs_get_query_results | No parameters |
| jobs_insert | configuration (undefined) etag (string) id (string) jobCreationReason (undefined) jobReference (undefined) kind (string) principal_subject (string) selfLink (string) statistics (undefined) status (undefined) user_email (string) |
| jobs_list | No parameters |
| jobs_query | connectionProperties (array) continuous (boolean) createSession (boolean) defaultDataset (undefined) destinationEncryptionConfiguration (undefined) dryRun (boolean) formatOptions (undefined) jobCreationMode (string) jobTimeoutMs (string) kind (string) labels (object) location (string) maxResults (integer) maximumBytesBilled (string) parameterMode (string) preserveNulls (boolean) query (string) queryParameters (array) requestId (string) reservation (string) timeoutMs (integer) useLegacySql (boolean) useQueryCache (boolean) writeIncrementalResults (boolean) |
| models_delete | No parameters |
| models_get | No parameters |
| models_list | No parameters |
| models_patch | bestTrialId (string) creationTime (string) defaultTrialId (string) description (string) encryptionConfiguration (undefined) etag (string) expirationTime (string) featureColumns (array) friendlyName (string) hparamSearchSpaces (undefined) hparamTrials (array) labelColumns (array) labels (object) lastModifiedTime (string) location (string) modelReference (undefined) modelType (string) optimalTrialIds (array) remoteModelInfo (undefined) trainingRuns (array) transformColumns (array) |
| projects_get_service_account | No parameters |
| projects_list | No parameters |
| routines_delete | No parameters |
| routines_get | No parameters |
| routines_get_iam_policy | options (undefined) |
| routines_insert | arguments (array) creationTime (string) dataGovernanceType (string) definitionBody (string) description (string) determinismLevel (string) etag (string) externalRuntimeOptions (undefined) importedLibraries (array) language (string) lastModifiedTime (string) pythonOptions (undefined) remoteFunctionOptions (undefined) returnTableType (undefined) returnType (undefined) routineReference (undefined) routineType (string) securityMode (string) sparkOptions (undefined) strictMode (boolean) |
| routines_list | No parameters |
| routines_set_iam_policy | policy (undefined) updateMask (string) |
| routines_test_iam_permissions | permissions (array) |
| routines_update | arguments (array) creationTime (string) dataGovernanceType (string) definitionBody (string) description (string) determinismLevel (string) etag (string) externalRuntimeOptions (undefined) importedLibraries (array) language (string) lastModifiedTime (string) pythonOptions (undefined) remoteFunctionOptions (undefined) returnTableType (undefined) returnType (undefined) routineReference (undefined) routineType (string) securityMode (string) sparkOptions (undefined) strictMode (boolean) |
| row_access_policies_batch_delete | force (boolean) policyIds (array) |
| row_access_policies_delete | No parameters |
| row_access_policies_get | No parameters |
| row_access_policies_get_iam_policy | options (undefined) |
| row_access_policies_insert | creationTime (string) etag (string) filterPredicate (string) grantees (array) lastModifiedTime (string) rowAccessPolicyReference (undefined) |
| row_access_policies_list | No parameters |
| row_access_policies_test_iam_permissions | permissions (array) |
| row_access_policies_update | creationTime (string) etag (string) filterPredicate (string) grantees (array) lastModifiedTime (string) rowAccessPolicyReference (undefined) |
| tabledata_insert_all | ignoreUnknownValues (boolean) kind (string) rows (array) skipInvalidRows (boolean) templateSuffix (string) traceId (string) |
| tabledata_list | No parameters |
| tables_delete | No parameters |
| tables_get | No parameters |
| tables_get_iam_policy | options (undefined) |
| tables_insert | biglakeConfiguration (undefined) cloneDefinition (undefined) clustering (undefined) creationTime (string) defaultCollation (string) defaultRoundingMode (string) description (string) encryptionConfiguration (undefined) etag (string) expirationTime (string) externalCatalogTableOptions (undefined) externalDataConfiguration (undefined) friendlyName (string) id (string) kind (string) labels (object) lastModifiedTime (string) location (string) managedTableType (string) materializedView (undefined) materializedViewStatus (undefined) maxStaleness (string) model (undefined) numActiveLogicalBytes (string) numActivePhysicalBytes (string) numBytes (string) numCurrentPhysicalBytes (string) numLongTermBytes (string) numLongTermLogicalBytes (string) numLongTermPhysicalBytes (string) numPartitions (string) numPhysicalBytes (string) numRows (string) numTimeTravelPhysicalBytes (string) numTotalLogicalBytes (string) numTotalPhysicalBytes (string) partitionDefinition (undefined) rangePartitioning (undefined) replicas (array) requirePartitionFilter (boolean) resourceTags (object) restrictions (undefined) schema (undefined) selfLink (string) snapshotDefinition (undefined) streamingBuffer (undefined) tableConstraints (undefined) tableReference (undefined) tableReplicationInfo (undefined) timePartitioning (undefined) type (string) view (undefined) |
| tables_list | No parameters |
| tables_patch | biglakeConfiguration (undefined) cloneDefinition (undefined) clustering (undefined) creationTime (string) defaultCollation (string) defaultRoundingMode (string) description (string) encryptionConfiguration (undefined) etag (string) expirationTime (string) externalCatalogTableOptions (undefined) externalDataConfiguration (undefined) friendlyName (string) id (string) kind (string) labels (object) lastModifiedTime (string) location (string) managedTableType (string) materializedView (undefined) materializedViewStatus (undefined) maxStaleness (string) model (undefined) numActiveLogicalBytes (string) numActivePhysicalBytes (string) numBytes (string) numCurrentPhysicalBytes (string) numLongTermBytes (string) numLongTermLogicalBytes (string) numLongTermPhysicalBytes (string) numPartitions (string) numPhysicalBytes (string) numRows (string) numTimeTravelPhysicalBytes (string) numTotalLogicalBytes (string) numTotalPhysicalBytes (string) partitionDefinition (undefined) rangePartitioning (undefined) replicas (array) requirePartitionFilter (boolean) resourceTags (object) restrictions (undefined) schema (undefined) selfLink (string) snapshotDefinition (undefined) streamingBuffer (undefined) tableConstraints (undefined) tableReference (undefined) tableReplicationInfo (undefined) timePartitioning (undefined) type (string) view (undefined) |
| tables_set_iam_policy | policy (undefined) updateMask (string) |
| tables_test_iam_permissions | permissions (array) |
| tables_update | biglakeConfiguration (undefined) cloneDefinition (undefined) clustering (undefined) creationTime (string) defaultCollation (string) defaultRoundingMode (string) description (string) encryptionConfiguration (undefined) etag (string) expirationTime (string) externalCatalogTableOptions (undefined) externalDataConfiguration (undefined) friendlyName (string) id (string) kind (string) labels (object) lastModifiedTime (string) location (string) managedTableType (string) materializedView (undefined) materializedViewStatus (undefined) maxStaleness (string) model (undefined) numActiveLogicalBytes (string) numActivePhysicalBytes (string) numBytes (string) numCurrentPhysicalBytes (string) numLongTermBytes (string) numLongTermLogicalBytes (string) numLongTermPhysicalBytes (string) numPartitions (string) numPhysicalBytes (string) numRows (string) numTimeTravelPhysicalBytes (string) numTotalLogicalBytes (string) numTotalPhysicalBytes (string) partitionDefinition (undefined) rangePartitioning (undefined) replicas (array) requirePartitionFilter (boolean) resourceTags (object) restrictions (undefined) schema (undefined) selfLink (string) snapshotDefinition (undefined) streamingBuffer (undefined) tableConstraints (undefined) tableReference (undefined) tableReplicationInfo (undefined) timePartitioning (undefined) type (string) view (undefined) |