Run Query
Execute a SQL query on BigQuery and return the results.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.RUN_QUERY])
Create Dataset
Create a new dataset in BigQuery to organize and contain tables.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.CREATE_DATASET])
Create Table
Create a new table in a specified dataset with defined schema.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.CREATE_TABLE])
Delete Dataset
Remove a dataset and all its contents from BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DELETE_DATASET])
Delete Table
Remove a specific table from a dataset in BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DELETE_TABLE])
Insert Rows
Insert new rows of data into a specified BigQuery table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.INSERT_ROWS])
Update Table Schema
Modify the schema of an existing table in BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.UPDATE_TABLE_SCHEMA])
Export Table
Export a BigQuery table to a specified destination like Google Cloud Storage.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.EXPORT_TABLE])
Import Data
Import data from external sources into a BigQuery table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.IMPORT_DATA])
Create View
Create a new view based on a SQL query in BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.CREATE_VIEW])
Grant Access
Grant access permissions to a user or service account for a dataset or table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.GRANT_ACCESS])
Revoke Access
Revoke access permissions from a user or service account for a dataset or table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.REVOKE_ACCESS])
Schedule Query
Set up a scheduled query to run automatically at specified intervals.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.SCHEDULE_QUERY])
Cancel Job
Cancel a running BigQuery job, such as a long-running query.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.CANCEL_JOB])
Create Partition
Create a new partition in a partitioned table for improved query performance.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.CREATE_PARTITION])
New Row Inserted
Triggered when a new row is inserted into a specified BigQuery table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.NEW_ROW_INSERTED])
Query Completed
Triggered when a BigQuery job (typically a query) completes execution.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.QUERY_COMPLETED])
Dataset Created
Triggered when a new dataset is created in BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DATASET_CREATED])
Table Created
Triggered when a new table is created in a BigQuery dataset.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.TABLE_CREATED])
Table Updated
Triggered when a table's schema or metadata is updated in BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.TABLE_UPDATED])
Query Error
Triggered when a BigQuery query fails or encounters an error during execution.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.QUERY_ERROR])
Storage Threshold Reached
Triggered when storage usage for a dataset or project reaches a specified threshold.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.STORAGE_THRESHOLD_REACHED])
Scheduled Query Started
Triggered when a scheduled query begins its execution.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.SCHEDULED_QUERY_STARTED])
Data Export Completed
Triggered when a data export job from BigQuery to external storage completes.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DATA_EXPORT_COMPLETED])
Access Changed
Triggered when access permissions are modified for a dataset or table.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.ACCESS_CHANGED])
Table Deleted
Triggered when a table is deleted from a BigQuery dataset.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.TABLE_DELETED])
Dataset Deleted
Triggered when a dataset is deleted from BigQuery.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DATASET_DELETED])
Query Timeout
Triggered when a BigQuery query exceeds its specified timeout duration.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.QUERY_TIMEOUT])
Data Staleness Alert
Triggered when data in a table hasn't been updated within a specified timeframe.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.DATA_STALENESS_ALERT])
Quota Exceeded
Triggered when a BigQuery quota (e.g., query bytes processed) is exceeded.
from composio_openai import ComposioToolSet, Action
tool_set = ComposioToolSet()
tools = tool_set.get_tools(actions=[Action.QUOTA_EXCEEDED])