Apache Airflow Provider - Google

An Apache Airflow provider for all Google services. Contains namespaces and modules for a variety of services, including Google Cloud, Google Ads, and GSuite.

Version
8.3.0
Downloads
1,466,267/month
Last Published
Aug. 14, 2022
Quick Install

Available Modules

Modules are Python callables available from this provider package.

Types:

OperatorsHooksTransfersSensorsSecretsLogTriggers
CloudDataCatalogUpdateEntryOperator
Google

Updates an existing entry.

OperatorsUpdated 14 days ago
CloudDataCatalogGetTagTemplateOperator
Google

Gets a tag template.

OperatorsUpdated 14 days ago
CloudDataCatalogRenameTagTemplateFieldOperator
Google

Renames a field in a tag template.

OperatorsUpdated 14 days ago
CloudDataCatalogLookupEntryOperator
Google

Get an entry by target resource name.

OperatorsUpdated 14 days ago
CloudDataCatalogSearchCatalogOperator
Google

Searches Data Catalog for multiple resources like entries, tags that match a query.

OperatorsUpdated 14 days ago
CloudDataCatalogUpdateTagTemplateOperator
Google

Updates a tag template.

OperatorsUpdated 14 days ago
CloudDataCatalogListTagsOperator
Google

Lists the tags on an Entry.

OperatorsUpdated 14 days ago
CloudDataCatalogUpdateTagOperator
Google

Updates an existing tag.

OperatorsUpdated 14 days ago
DataflowCreateJavaJobOperator
Google

Start a Java Cloud Dataflow batch job. The parameters of the operation will be passed to the job.

OperatorsUpdated 14 days ago
DataflowStartSqlJobOperator
Google

Starts Dataflow SQL query.

OperatorsUpdated 14 days ago
CloudDataCatalogUpdateTagTemplateFieldOperator
Google

Updates a field in a tag template. This method cannot be used to update the field type.

OperatorsUpdated 14 days ago
DataflowTemplatedJobStartOperator
Google

Start a Templated Cloud Dataflow job. The parameters of the operation will be passed to the job.

OperatorsUpdated 14 days ago
DataflowStartFlexTemplateOperator
Google

Starts flex templates with the Dataflow pipeline.

OperatorsUpdated 14 days ago
GoogleSearchAdsHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
ComputeEngineBaseOperator
Google

Abstract base operator for Google Compute Engine operators to inherit from.

OperatorsUpdated 8 months ago
ComputeEngineHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
AutoMLBatchPredictOperator
Google

Perform a batch prediction on Google Cloud AutoML.

OperatorsUpdated 14 days ago
AutoMLDeleteModelOperator
Google

Delete Google Cloud AutoML model.

OperatorsUpdated 14 days ago
AutoMLGetModelOperator
Google

Get Google Cloud AutoML model.

OperatorsUpdated 14 days ago
AutoMLCreateDatasetOperator
Google

Creates a Google Cloud AutoML dataset.

OperatorsUpdated 14 days ago
AutoMLDeleteDatasetOperator
Google

Deletes a dataset and all of its contents.

OperatorsUpdated 14 days ago
AutoMLDeployModelOperator
Google

Deploys a model. If a model is already deployed, deploying it with the same parameters has no effect. Deploying with different parameters (as e.g. cha…

OperatorsUpdated 14 days ago
AutoMLPredictOperator
Google

Runs prediction operation on Google Cloud AutoML.

OperatorsUpdated 14 days ago
AutoMLImportDataOperator
Google

Imports data to a Google Cloud AutoML dataset.

OperatorsUpdated 14 days ago
AutoMLTablesUpdateDatasetOperator
Google

Updates a dataset.

OperatorsUpdated 14 days ago
AutoMLTrainModelOperator
Google

Creates Google Cloud AutoML model.

OperatorsUpdated 14 days ago
AutoMLTablesListTableSpecsOperator
Google

Lists table specs in a dataset.

OperatorsUpdated 14 days ago
BigQueryCheckOperator
Google

Performs checks against BigQuery. The BigQueryCheckOperator expects a sql query that will return a single row. Each value on that first row is evaluat…

OperatorsUpdated 7 days ago
BigQueryCreateEmptyDatasetOperator
Google

This operator is used to create new dataset for your Project in BigQuery. https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets#resource

OperatorsUpdated 7 days ago
BigQueryCreateDataTransferOperator
Google

Creates a new data transfer configuration.

OperatorsUpdated 14 days ago
AzureFileShareToGCSOperator
Google

Synchronizes a Azure FileShare directory content (excluding subdirectories), possibly filtered by a prefix, with a Google Cloud Storage destination pa…

TransfersUpdated 14 days ago
BigQueryCreateExternalTableOperator
Google

Creates a new external table in the dataset with the data from Google Cloud Storage.

OperatorsUpdated 7 days ago
BigQueryDataTransferServiceTransferRunSensor
Google

Waits for Data Transfer Service run to complete.

SensorsUpdated 14 days ago
BigQueryDeleteDataTransferConfigOperator
Google

Deletes transfer configuration.

OperatorsUpdated 14 days ago
BigQueryDeleteTableOperator
Google

Deletes BigQuery tables

OperatorsUpdated 7 days ago
CloudMemorystoreMemcachedGetInstanceOperator
Google

Gets the details of a specific Memcached instance.

OperatorsUpdated 14 days ago
CloudSQLCreateInstanceOperator
Google

Creates a new Cloud SQL instance. If an instance with the same name exists, no action will be taken and the operator will succeed.

OperatorsUpdated 14 days ago
CloudSQLDeleteInstanceDatabaseOperator
Google

Deletes a database from a Cloud SQL instance.

OperatorsUpdated 14 days ago
CloudMemorystoreMemcachedDeleteInstanceOperator
Google

Deletes a specific Memcached instance. Instance stops serving and data is deleted.

OperatorsUpdated 14 days ago
AutoMLListDatasetOperator
Google

Lists AutoML Datasets in project.

OperatorsUpdated 14 days ago
BigQueryIntervalCheckOperator
Google

Checks that the values of metrics given as SQL expressions are within a certain tolerance of the ones from days_back before.

OperatorsUpdated 7 days ago
CloudSQLDeleteInstanceOperator
Google

Deletes a Cloud SQL instance.

OperatorsUpdated 14 days ago
BigQueryTableExistenceSensor
Google

Checks for the existence of a table in Google Bigquery.

SensorsUpdated 8 days ago
BigQueryTablePartitionExistenceSensor
Google

Checks for the existence of a partition within a table in Google Bigquery.

SensorsUpdated 8 days ago
BigQueryToGCSOperator
Google

Transfers a BigQuery table to a Google Cloud Storage bucket.

TransfersUpdated 14 days ago
BigQueryUpsertTableOperator
Google

Upsert BigQuery table

OperatorsUpdated 7 days ago
BigQueryToMySqlOperator
Google

Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and insert that data into a MySQL table.

TransfersUpdated 14 days ago
BigQueryUpdateTableOperator
Google

This operator is used to update table for your Project in BigQuery. Use fields to specify which fields of table to update. If a field is listed in fie…

OperatorsUpdated 7 days ago
BigQueryValueCheckOperator
Google

Performs a simple value check using sql code.

OperatorsUpdated 7 days ago
BigtableCreateInstanceOperator
Google

Creates a new Cloud Bigtable instance. If the Cloud Bigtable instance with the given ID exists, the operator does not compare its configuration and im…

OperatorsUpdated 14 days ago
DataflowHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
BigtableCreateTableOperator
Google

Creates the table in the Cloud Bigtable instance.

OperatorsUpdated 14 days ago
CloudSQLExecuteQueryOperator
Google

Performs DML or DDL query on an existing Cloud Sql instance. It optionally uses cloud-sql-proxy to establish secure connection with the database.

OperatorsUpdated 14 days ago
BigQueryToBigQueryOperator
Google

Copies data from one BigQuery table to another.

TransfersUpdated 14 days ago
BigQueryPatchDatasetOperator
Google

This operator is used to patch dataset for your Project in BigQuery. It only replaces fields that are provided in the submitted dataset resource.

OperatorsUpdated 7 days ago
BigtableHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
BigtableTableReplicationCompletedSensor
Google

Sensor that waits for Cloud Bigtable table to be fully replicated to its clusters. No exception will be raised if the instance or the table does not e…

SensorsUpdated 14 days ago
BigQueryCreateEmptyTableOperator
Google

Creates a new, empty table in the specified BigQuery dataset, optionally with schema.

OperatorsUpdated 7 days ago
BigtableUpdateClusterOperator
Google

Updates a Cloud Bigtable cluster.

OperatorsUpdated 14 days ago
CassandraToGCSOperator
Google

Copy data from Cassandra to Google Cloud Storage in JSON format

TransfersUpdated 14 days ago
BiqQueryDataTransferServiceHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
BigQueryUpdateDatasetOperator
Google

This operator is used to update dataset for your Project in BigQuery. Use fields to specify which fields of dataset to update. If a field is listed in…

OperatorsUpdated 7 days ago
BigQueryDataTransferServiceStartTransferRunsOperator
Google

Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the ru…

OperatorsUpdated 14 days ago
CloudBuildCreateBuildOperator
Google

Starts a build with the specified configuration.

OperatorsUpdated 14 days ago
CloudSQLCreateInstanceDatabaseOperator
Google

Creates a new database inside a Cloud SQL instance.

OperatorsUpdated 14 days ago
CloudBuildHook
Google

Hook for the Google Cloud Build Service.

HooksUpdated 14 days ago
CloudDLPCreateDLPJobOperator
Google

Creates a new job to inspect storage or calculate risk metrics.

OperatorsUpdated a day ago
CloudAutoMLHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudDLPCreateDeidentifyTemplateOperator
Google

Creates a DeidentifyTemplate for re-using frequently used configuration for de-identifying content, images, and storage.

OperatorsUpdated a day ago
CloudDLPCreateInspectTemplateOperator
Google

Creates an InspectTemplate for re-using frequently used configuration for inspecting content, images, and storage.

OperatorsUpdated a day ago
CloudDLPCancelDLPJobOperator
Google

Starts asynchronous cancellation on a long-running DlpJob.

OperatorsUpdated a day ago
CloudSQLDatabaseHook
Google

Serves DB connection configuration for Google Cloud SQL (Connections of gcpcloudsqldb:// type).

HooksUpdated 14 days ago
BigQueryDeleteDatasetOperator
Google

This operator deletes an existing dataset from your Project in Big query. https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets/delete

OperatorsUpdated 7 days ago
CloudDLPCreateJobTriggerOperator
Google

Creates a job trigger to run DLP actions such as scanning storage for sensitive information on a set schedule.

OperatorsUpdated a day ago
CloudDLPDeidentifyContentOperator
Google

De-identifies potentially sensitive info from a ContentItem. This method has limits on input size and output size.

OperatorsUpdated a day ago
CloudDLPDeleteDLPJobOperator
Google

Deletes a long-running DlpJob. This method indicates that the client is no longer interested in the DlpJob result. The job will be cancelled if possib…

OperatorsUpdated a day ago
BigQueryExecuteQueryOperator
Google

Executes BigQuery SQL queries in a specific BigQuery database. This operator does not assert idempotency.

OperatorsUpdated 7 days ago
BigQueryGetDataOperator
Google

Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and returns data in a python list. The number of elements in th…

OperatorsUpdated 7 days ago
BigQueryGetDatasetOperator
Google

This operator is used to return the dataset specified by dataset_id.

OperatorsUpdated 7 days ago
BigtableUpdateInstanceOperator
Google

Updates an existing Cloud Bigtable instance.

OperatorsUpdated 14 days ago
BigQueryInsertJobOperator
Google

Executes a BigQuery job. Waits for the job to complete and returns job id. This operator work in the following way:

OperatorsUpdated 7 days ago
CloudDLPDeleteDeidentifyTemplateOperator
Google

Deletes a DeidentifyTemplate.

OperatorsUpdated a day ago
BigtableDeleteInstanceOperator
Google

Deletes the Cloud Bigtable instance, including its clusters and all related tables.

OperatorsUpdated 14 days ago
DataFusionHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 10 days ago
BigtableDeleteTableOperator
Google

Deletes the Cloud Bigtable table.

OperatorsUpdated 14 days ago
CloudDLPDeleteJobTriggerOperator
Google

Deletes a job trigger.

OperatorsUpdated a day ago
CloudDLPDeleteInspectTemplateOperator
Google

Deletes an InspectTemplate.

OperatorsUpdated a day ago
BigQueryGetDatasetTablesOperator
Google

This operator retrieves the list of tables in the specified dataset.

OperatorsUpdated 7 days ago
CloudDLPGetDLPJobOperator
Google

Gets the latest state of a long-running DlpJob.

OperatorsUpdated a day ago
CloudDLPGetDeidentifyTemplateOperator
Google

Gets a DeidentifyTemplate.

OperatorsUpdated a day ago
CloudDLPGetDLPJobTriggerOperator
Google

Gets a job trigger.

OperatorsUpdated a day ago
CloudDLPGetStoredInfoTypeOperator
Google

Gets a stored infoType.

OperatorsUpdated a day ago
CloudDLPGetInspectTemplateOperator
Google

Gets an InspectTemplate.

OperatorsUpdated a day ago
CloudDLPListDLPJobsOperator
Google

Lists DlpJobs that match the specified filter in the request.

OperatorsUpdated a day ago
CloudDLPInspectContentOperator
Google

Finds potentially sensitive info in content. This method has limits on input size, processing time, and output size.

OperatorsUpdated a day ago
CloudDLPListDeidentifyTemplatesOperator
Google

Lists DeidentifyTemplates.

OperatorsUpdated a day ago
CloudDLPListInfoTypesOperator
Google

Returns a list of the sensitive information types that the DLP API supports.

OperatorsUpdated a day ago
CloudDLPCreateStoredInfoTypeOperator
Google

Creates a pre-built stored infoType to be used for inspection.

OperatorsUpdated a day ago
AutoMLTablesListColumnSpecsOperator
Google

Lists column specs in a table.

OperatorsUpdated 14 days ago
CloudDLPListStoredInfoTypesOperator
Google

Lists stored infoTypes.

OperatorsUpdated a day ago
CloudDLPRedactImageOperator
Google

Redacts potentially sensitive info from an image. This method has limits on input size, processing time, and output size.

OperatorsUpdated a day ago
CloudDataTransferServiceHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 6 days ago
BigQueryHook
Google

Interact with BigQuery. This hook uses the Google Cloud connection.

HooksUpdated 8 days ago
CloudMemorystoreScaleInstanceOperator
Google

Updates the metadata and configuration of a specific Redis instance.

OperatorsUpdated 14 days ago
CloudMemorystoreMemcachedListInstancesOperator
Google

locations.

OperatorsUpdated 14 days ago
CloudNaturalLanguageHook
Google

Hook for Google Cloud Natural Language Service.

HooksUpdated 14 days ago
CloudMemorystoreMemcachedUpdateInstanceOperator
Google

Updates the metadata and configuration of a specific Memcached instance.

OperatorsUpdated 14 days ago
CloudMemorystoreMemcachedUpdateParametersOperator
Google

parameters, it must be followed by apply_parameters to apply the parameters to nodes of the Memcached Instance.

OperatorsUpdated 14 days ago
CloudSQLExportInstanceOperator
Google

Exports data from a Cloud SQL instance to a Cloud Storage bucket as a SQL dump or CSV file.

OperatorsUpdated 14 days ago
CloudSQLBaseOperator
Google

Abstract base operator for Google Cloud SQL operators to inherit from.

OperatorsUpdated 14 days ago
DataprepRunJobGroupOperator
Google

Create a jobGroup, which launches the specified job as the authenticated user. This performs the same action as clicking on the Run Job button in the …

OperatorsUpdated 14 days ago
DataprocCreateWorkflowTemplateOperator
Google

Creates new workflow template.

OperatorsUpdated 14 days ago
DataprocDeleteClusterOperator
Google

Deletes a cluster in a project.

OperatorsUpdated 14 days ago
CloudDLPReidentifyContentOperator
Google

Re-identifies content that has been de-identified.

OperatorsUpdated a day ago
CloudDLPUpdateDeidentifyTemplateOperator
Google

Updates the DeidentifyTemplate.

OperatorsUpdated a day ago
CloudTasksQueueDeleteOperator
Google

Deletes a queue from Cloud Tasks, even if it has tasks in it.

OperatorsUpdated 14 days ago
CloudTasksTasksListOperator
Google

Lists the tasks in Cloud Tasks.

OperatorsUpdated 14 days ago
MLEngineCreateModelOperator
Google

Creates a new model.

OperatorsUpdated 14 days ago
CloudDLPHook
Google

Hook for Google Cloud Data Loss Prevention (DLP) APIs. Cloud DLP allows clients to detect the presence of Personally Identifiable Information (PII) an…

HooksUpdated 14 days ago
CloudTasksQueueGetOperator
Google

Gets a queue from Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTextToSpeechSynthesizeOperator
Google

Synthesizes text to speech and stores it in Google Cloud Storage

OperatorsUpdated 14 days ago
CloudDLPListInspectTemplatesOperator
Google

Lists InspectTemplates.

OperatorsUpdated a day ago
CloudDLPUpdateInspectTemplateOperator
Google

Updates the InspectTemplate.

OperatorsUpdated a day ago
CloudDataCatalogCreateEntryGroupOperator
Google

Creates an EntryGroup.

OperatorsUpdated 14 days ago
CloudDLPUpdateStoredInfoTypeOperator
Google

Updates the stored infoType by creating a new version.

OperatorsUpdated a day ago
CloudDataCatalogHook
Google

Hook for Google Cloud Data Catalog Service.

HooksUpdated 14 days ago
CloudDataFusionCreateInstanceOperator
Google

Creates a new Data Fusion instance in the specified project and location.

OperatorsUpdated 14 days ago
CloudMemorystoreExportAndDeleteInstanceOperator
Google

Export Redis instance data into a Redis RDB format file in Cloud Storage. In next step, deletes a this instance.

OperatorsUpdated 14 days ago
CloudDataFusionCreatePipelineOperator
Google

Creates a Cloud Data Fusion pipeline.

OperatorsUpdated 14 days ago
CloudMemorystoreUpdateInstanceOperator
Google

Updates the metadata and configuration of a specific Redis instance.

OperatorsUpdated 14 days ago
CloudDataFusionDeletePipelineOperator
Google

Deletes a Cloud Data Fusion pipeline.

OperatorsUpdated 14 days ago
CloudDataCatalogGetEntryOperator
Google

Gets an entry.

OperatorsUpdated 14 days ago
CloudDataFusionListPipelinesOperator
Google

Lists Cloud Data Fusion pipelines.

OperatorsUpdated 14 days ago
CloudDataFusionRestartInstanceOperator
Google

Restart a single Data Fusion instance. At the end of an operation instance is fully restarted.

OperatorsUpdated 14 days ago
CloudTextToSpeechHook
Google

Hook for Google Cloud Text to Speech API.

HooksUpdated 14 days ago
CloudDataFusionStopPipelineOperator
Google

Stops a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.

OperatorsUpdated 14 days ago
CloudDataFusionGetInstanceOperator
Google

Gets details of a single Data Fusion instance.

OperatorsUpdated 14 days ago
DataprocCreateClusterOperator
Google

Create a new cluster on Google Cloud Dataproc. The operator will wait until the creation is successful or an error occurs in the creation process. If …

OperatorsUpdated 14 days ago
CloudDataTransferServiceDeleteJobOperator
Google

Delete a transfer job. This is a soft delete. After a transfer job is deleted, the job and all the transfer executions are subject to garbage collecti…

OperatorsUpdated 6 days ago
CloudDataTransferServiceGCSToGCSOperator
Google

Copies objects from a bucket to another using the Google Cloud Storage Transfer Service.

OperatorsUpdated 6 days ago
CloudDataTransferServiceGetOperationOperator
Google

Gets the latest state of a long-running operation in Google Storage Transfer Service.

OperatorsUpdated 6 days ago
CloudDataTransferServiceJobStatusSensor
Google

Waits for at least one operation belonging to the job to have the expected status.

SensorsUpdated 6 days ago
CloudDataTransferServicePauseOperationOperator
Google

Pauses a transfer operation in Google Storage Transfer Service.

OperatorsUpdated 6 days ago
LocalFilesystemToGCSOperator
Google

Uploads a file or list of files to Google Cloud Storage. Optionally can compress the file for upload.

TransfersUpdated 14 days ago
CloudDatastoreAllocateIdsOperator
Google

Allocate IDs for incomplete keys. Return list of keys.

OperatorsUpdated 14 days ago
CloudDataTransferServiceCreateJobOperator
Google

Creates a transfer job that runs periodically.

OperatorsUpdated 6 days ago
CloudDatastoreCommitOperator
Google

Commit a transaction, optionally creating, deleting or modifying some entities.

OperatorsUpdated 14 days ago
CloudDatastoreDeleteOperationOperator
Google

Deletes the long-running operation.

OperatorsUpdated 14 days ago
CloudDataTransferServiceListOperationsOperator
Google

Lists long-running operations in Google Storage Transfer Service that match the specified filter.

OperatorsUpdated 6 days ago
CloudDatastoreGetOperationOperator
Google

Gets the latest state of a long-running operation.

OperatorsUpdated 14 days ago
CloudDatastoreImportEntitiesOperator
Google

Import entities from Cloud Storage to Google Cloud Datastore

OperatorsUpdated 14 days ago
CloudDataTransferServiceUpdateJobOperator
Google

Updates a transfer job that runs periodically.

OperatorsUpdated 6 days ago
CloudDatastoreRollbackOperator
Google

Roll back a transaction.

OperatorsUpdated 14 days ago
CloudDataFusionDeleteInstanceOperator
Google

Deletes a single Date Fusion instance.

OperatorsUpdated 14 days ago
CloudDatastoreRunQueryOperator
Google

Run a query for entities. Returns the batch of query results.

OperatorsUpdated 14 days ago
CloudFirestoreExportDatabaseOperator
Google

Exports a copy of all or a subset of documents from Google Cloud Firestore to another storage system, such as Google Cloud Storage.

OperatorsUpdated 14 days ago
CloudFunctionDeployFunctionOperator
Google

Creates a function in Google Cloud Functions. If a function with this name already exists, it will be updated.

OperatorsUpdated 9 days ago
CloudKMSHook
Google

Hook for Google Cloud Key Management service.

HooksUpdated 14 days ago
CloudDataTransferServiceCancelOperationOperator
Google

Cancels a transfer operation in Google Storage Transfer Service.

OperatorsUpdated 6 days ago
CloudFunctionsHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudMemorystoreMemcachedHook
Google

Hook for Google Cloud Memorystore for Memcached service APIs.

HooksUpdated 14 days ago
ComputeEngineSSHHook
Google

Hook to connect to a remote instance in compute engine

HooksUpdated 14 days ago
DataprocHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudDLPListJobTriggersOperator
Google

Lists job triggers.

OperatorsUpdated a day ago
WorkflowsHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudDataTransferServiceS3ToGCSOperator
Google

Synchronizes an S3 bucket with a Google Cloud Storage bucket using the Google Cloud Storage Transfer Service.

OperatorsUpdated 6 days ago
ComputeEngineCopyInstanceTemplateOperator
Google

Copies the instance template, applying specified changes.

OperatorsUpdated 14 days ago
ComputeEngineInstanceGroupUpdateManagerTemplateOperator
Google

Patches the Instance Group Manager, replacing source template URL with the destination one. API V1 does not have update/patch operations for Instance …

OperatorsUpdated 14 days ago
CloudDataFusionStartPipelineOperator
Google

Starts a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.

OperatorsUpdated 14 days ago
DataflowCreatePythonJobOperator
Google

Launching Cloud Dataflow jobs written in python. Note that both dataflow_default_options and options will be merged to specify pipeline execution para…

OperatorsUpdated 14 days ago
CloudDatastoreExportEntitiesOperator
Google

Export entities from Google Cloud Datastore to Cloud Storage

OperatorsUpdated 14 days ago
CloudDataFusionUpdateInstanceOperator
Google

Updates a single Data Fusion instance.

OperatorsUpdated 14 days ago
DataprocSubmitHadoopJobOperator
Google

Start a Hadoop Job on a Cloud DataProc cluster.

OperatorsUpdated 14 days ago
DataprocSubmitSparkJobOperator
Google

Start a Spark Job on a Cloud DataProc cluster.

OperatorsUpdated 14 days ago
DataprocInstantiateWorkflowTemplateOperator
Google

Instantiate a WorkflowTemplate on Google Cloud Dataproc. The operator will wait until the WorkflowTemplate is finished executing.

OperatorsUpdated 14 days ago
GCSSynchronizeBucketsOperator
Google

Synchronizes the contents of the buckets or bucket’s directories in the Google Cloud Services.

OperatorsUpdated 14 days ago
CloudFunctionDeleteFunctionOperator
Google

Deletes the specified function from Google Cloud Functions.

OperatorsUpdated 9 days ago
GCSListObjectsOperator
Google

List all objects from the bucket with the given string prefix and delimiter in name.

OperatorsUpdated 14 days ago
GCSDeleteBucketOperator
Google

Deletes bucket from a Google Cloud Storage.

OperatorsUpdated 14 days ago
GCSDeleteObjectsOperator
Google

Deletes objects from a Google Cloud Storage bucket, either from an explicit list of object names or all objects matching a prefix.

OperatorsUpdated 14 days ago
CloudNaturalLanguageAnalyzeEntitiesOperator
Google

Finds named entities in the text along with entity types, salience, mentions for each entity, and other properties.

OperatorsUpdated 14 days ago
SpannerDeleteDatabaseInstanceOperator
Google

Deletes a Cloud Spanner database.

OperatorsUpdated 14 days ago
StackdriverDisableAlertPoliciesOperator
Google

Disables one or more enabled alerting policies identified by filter parameter. Inoperative in case the policy is already disabled.

OperatorsUpdated 14 days ago
SpannerDeployInstanceOperator
Google

Creates a new Cloud Spanner instance, or if an instance with the same instance_id exists in the specified project, updates the Cloud Spanner instance.

OperatorsUpdated 14 days ago
CloudVisionAddProductToProductSetOperator
Google

Adds a Product to the specified ProductSet. If the Product is already present, no change is made.

OperatorsUpdated 14 days ago
CloudTasksQueuePurgeOperator
Google

Purges a queue by deleting all of its tasks from Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTasksQueuePauseOperator
Google

Pauses a queue in Cloud Tasks.

OperatorsUpdated 14 days ago
CloudVideoIntelligenceDetectVideoShotsOperator
Google

Performs video annotation, annotating video shots.

OperatorsUpdated 14 days ago
DataflowJobMetricsSensor
Google

Checks the metrics of a job in Google Cloud Dataflow.

SensorsUpdated 14 days ago
WorkflowsListExecutionsOperator
Google

Returns a list of executions which belong to the workflow with the given name. The method returns executions of all workflow revisions. Returned execu…

OperatorsUpdated 14 days ago
WorkflowsListWorkflowsOperator
Google

Lists Workflows in a given project and location. The default order is not specified.

OperatorsUpdated 14 days ago
FacebookAdsReportToGcsOperator
Google

Fetches the results from the Facebook Ads API as desired in the params Converts and saves the data as a temporary JSON file Uploads the JSON to Google…

TransfersUpdated 14 days ago
GCSObjectsWithPrefixExistenceSensor
Google

Checks for the existence of GCS objects at a given prefix, passing matches via XCom.

SensorsUpdated 14 days ago
GCSObjectExistenceSensor
Google

Checks for the existence of a file in Google Cloud Storage.

SensorsUpdated 14 days ago
GoogleBaseHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
GCSObjectUpdateSensor
Google

Checks if an object is updated in Google Cloud Storage.

SensorsUpdated 14 days ago
CloudMemorystoreCreateInstanceAndImportOperator
Google

Creates a Redis instance based on the specified tier and memory size and import a Redis RDB snapshot file from Cloud Storage into a this instance.

OperatorsUpdated 14 days ago
TrinoToGCSOperator
Google

Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
CloudDatastoreBeginTransactionOperator
Google

Begins a new transaction. Returns a transaction handle.

OperatorsUpdated 14 days ago
CloudMemorystoreHook
Google

Hook for Google Cloud Memorystore APIs.

HooksUpdated 14 days ago
CloudMemorystoreMemcachedApplyParametersOperator
Google

Will update current set of Parameters to the set of specified nodes of the Memcached Instance.

OperatorsUpdated 14 days ago
CloudSQLImportInstanceOperator
Google

Imports data into a Cloud SQL instance from a SQL dump or CSV file in Cloud Storage.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360CreateSDFDownloadTaskOperator
Google

Creates SDF operation task.

OperatorsUpdated 14 days ago
CloudSecretManagerBackend
Google

Retrieves Connection object from Google Cloud Secrets Manager

SecretsUpdated 14 days ago
CloudSpeechToTextRecognizeSpeechOperator
Google

Recognizes speech from audio file and returns it as text.

OperatorsUpdated 14 days ago
CloudTasksQueueCreateOperator
Google

Creates a queue in Cloud Tasks.

OperatorsUpdated 14 days ago
GCSToGoogleDriveOperator
Google

Copies objects from a Google Cloud Storage service to a Google Drive service, with renaming if requested.

TransfersUpdated 14 days ago
CloudSQLInstancePatchOperator
Google

Updates settings of a Cloud SQL instance.

OperatorsUpdated 14 days ago
CloudVideoIntelligenceDetectVideoExplicitContentOperator
Google

Performs video annotation, annotating explicit content.

OperatorsUpdated 14 days ago
CloudTasksTaskDeleteOperator
Google

Deletes a task from Cloud Tasks.

OperatorsUpdated 14 days ago
CloudVisionCreateProductSetOperator
Google

Creates a new ProductSet resource.

OperatorsUpdated 14 days ago
DataprocInstantiateInlineWorkflowTemplateOperator
Google

Instantiate a WorkflowTemplate Inline on Google Cloud Dataproc. The operator will wait until the WorkflowTemplate is finished executing.

OperatorsUpdated 14 days ago
DataprocSubmitJobOperator
Google

Submits a job to a cluster.

OperatorsUpdated 14 days ago
DataflowJobAutoScalingEventsSensor
Google

Checks for the job autoscaling event in Google Cloud Dataflow.

SensorsUpdated 14 days ago
DataflowJobMessagesSensor
Google

Checks for the job message in Google Cloud Dataflow.

SensorsUpdated 14 days ago
CloudVisionRemoveProductFromProductSetOperator
Google

Removes a Product from the specified ProductSet.

OperatorsUpdated 14 days ago
CloudMemorystoreExportInstanceOperator
Google

Export Redis instance data into a Redis RDB format file in Cloud Storage.

OperatorsUpdated 14 days ago
GCSTaskHandler
Google

GCSTaskHandler is a python log handler that handles and reads task instance logs. It extends airflow FileTaskHandler and uploads to and reads from GCS…

LogUpdated 9 days ago
CloudMemorystoreFailoverInstanceOperator
Google

Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.

OperatorsUpdated 14 days ago
GCSTimeSpanFileTransformOperator
Google

Determines a list of objects that were added or modified at a GCS source location during a specific time-span, copies them to a temporary location on …

OperatorsUpdated 14 days ago
GCSObjectsWtihPrefixExistenceSensor
Google

This class is deprecated. Please use airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor.

SensorsUpdated 5 months ago
GCSToBigQueryOperator
Google

Loads files from Google Cloud Storage into BigQuery.

TransfersUpdated 9 days ago
GCSToLocalFilesystemOperator
Google

Downloads a file from Google Cloud Storage.

TransfersUpdated 14 days ago
GCSUploadSessionCompleteSensor
Google

Checks for changes in the number of objects at prefix in Google Cloud Storage bucket and returns True if the inactivity period has passed with no incr…

SensorsUpdated 14 days ago
GKECreateClusterOperator
Google

Create a Google Kubernetes Engine Cluster of specified dimensions The operator will wait until the cluster is created.

OperatorsUpdated 14 days ago
GKEStartPodOperator
Google

Executes a task in a Kubernetes pod in the specified Google Kubernetes Engine cluster

OperatorsUpdated 14 days ago
GSheetsHook
Google

Interact with Google Sheets via Google Cloud connection Reading and writing cells in Google Sheet: https://developers.google.com/sheets/api/guides/val…

HooksUpdated 14 days ago
GoogleAdsToGcsOperator
Google

Fetches the daily results from the Google Ads API for 1-n clients Converts and saves the data as a temporary CSV file Uploads the CSV to Google Cloud …

TransfersUpdated 14 days ago
GoogleAnalyticsDataImportUploadOperator
Google

Take a file from Cloud Storage and uploads it to GA via data import API.

OperatorsUpdated 14 days ago
GoogleAdsHook
Google

Hook for the Google Ads API.

HooksUpdated 14 days ago
GoogleAnalyticsHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
StackdriverListNotificationChannelsOperator
Google

Fetches all the Notification Channels identified by the filter passed as filter parameter. The desired return type can be specified by the format para…

OperatorsUpdated 14 days ago
StackdriverUpsertAlertOperator
Google

Creates a new alert or updates an existing policy identified the name field in the alerts parameter.

OperatorsUpdated 14 days ago
CloudMemorystoreGetInstanceOperator
Google

Gets the details of a specific Redis instance.

OperatorsUpdated 14 days ago
GoogleAnalyticsGetAdsLinkOperator
Google

Returns a web property-Google Ads link to which the user has access.

OperatorsUpdated 14 days ago
CloudMemorystoreDeleteInstanceOperator
Google

Deletes a specific Redis instance. Instance stops serving and data is deleted.

OperatorsUpdated 14 days ago
StackdriverListAlertPoliciesOperator
Google

Fetches all the Alert Policies identified by the filter passed as filter parameter. The desired return type can be specified by the format parameter, …

OperatorsUpdated 14 days ago
GCSToGCSOperator
Google

Copies objects from a bucket to another, with renaming if requested.

TransfersUpdated 14 days ago
CloudDLPDeleteStoredInfoTypeOperator
Google

Deletes a stored infoType.

OperatorsUpdated a day ago
GCSToSFTPOperator
Google

Transfer files from a Google Cloud Storage bucket to SFTP server.

TransfersUpdated 14 days ago
DatastoreHook
Google

Interact with Google Cloud Datastore. This hook uses the Google Cloud connection.

HooksUpdated 14 days ago
GKEHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 8 days ago
GoogleAnalyticsRetrieveAdsLinksListOperator
Google

Lists webProperty-Google Ads links for a given web property

OperatorsUpdated 14 days ago
GoogleSheetsToGCSOperator
Google

Writes Google Sheet data into Google Cloud Storage.

TransfersUpdated 14 days ago
GoogleCampaignManagerBatchInsertConversionsOperator
Google

Inserts conversions.

OperatorsUpdated 14 days ago
GoogleCampaignManagerBatchUpdateConversionsOperator
Google

Updates existing conversions.

OperatorsUpdated 14 days ago
GoogleAdsListAccountsOperator
Google

Saves list of customers on GCS in form of a csv file.

OperatorsUpdated 14 days ago
GoogleCampaignManagerDeleteReportOperator
Google

Deletes a report by its ID.

OperatorsUpdated 14 days ago
GoogleCampaignManagerHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
GoogleCampaignManagerDownloadReportOperator
Google

Retrieves a report and uploads it to GCS bucket.

OperatorsUpdated 14 days ago
GoogleCampaignManagerInsertReportOperator
Google

Creates a report.

OperatorsUpdated 14 days ago
GoogleAnalyticsDeletePreviousDataUploadsOperator
Google

Deletes previous GA uploads to leave the latest file to control the size of the Data Set Quota.

OperatorsUpdated 14 days ago
GoogleDataprepHook
Google

Abstract base class for hooks, hooks are meant as an interface to interact with external systems. MySqlHook, HiveHook, PigHook return object that can …

HooksUpdated 14 days ago
GoogleDeploymentManagerHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
GoogleCampaignManagerReportSensor
Google

Check if report is ready.

SensorsUpdated 14 days ago
GoogleAnalyticsModifyFileHeadersDataImportOperator
Google

GA has a very particular naming convention for Data Import. Ability to prefix “ga:” to all column headers and also a dict to rename columns to match t…

OperatorsUpdated 14 days ago
GoogleDiscoveryApiHook
Google

A hook to use the Google API Discovery Service.

HooksUpdated 14 days ago
GoogleDisplayVideo360DownloadReportOperator
Google

Retrieves a stored query.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360CreateReportOperator
Google

Creates a query.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360DownloadLineItemsOperator
Google

Retrieves line items in CSV format.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360DeleteReportOperator
Google

Deletes a stored query as well as the associated stored reports.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360GetSDFDownloadOperationSensor
Google

Sensor for detecting the completion of SDF operation.

SensorsUpdated 14 days ago
GoogleDisplayVideo360Hook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
WorkflowsGetExecutionOperator
Google

Returns an execution for the given workflow_id and execution_id.

OperatorsUpdated 14 days ago
WorkflowsUpdateWorkflowOperator
Google

Updates an existing workflow. Running this method has no impact on already running executions of the workflow. A new revision of the workflow may be c…

OperatorsUpdated 14 days ago
CloudDataCatalogDeleteTagOperator
Google

Deletes a tag.

OperatorsUpdated 14 days ago
CloudDataCatalogDeleteEntryOperator
Google

Deletes an existing entry.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360ReportSensor
Google

Sensor for detecting the completion of DV360 reports.

SensorsUpdated 14 days ago
WorkflowsGetWorkflowOperator
Google

Gets details of a single Workflow.

OperatorsUpdated 14 days ago
GoogleDriveToLocalOperator
Google

Writes a Google Drive file into local Storage.

TransfersUpdated 14 days ago
GCSToGoogleSheetsOperator
Google

Uploads .csv file from Google Cloud Storage to provided Google Spreadsheet.

TransfersUpdated 14 days ago
GoogleAnalyticsListAccountsOperator
Google

Lists all accounts to which the user has access.

OperatorsUpdated 14 days ago
CloudDataCatalogCreateTagOperator
Google

Creates a tag on an entry.

OperatorsUpdated 14 days ago
CloudDataCatalogCreateEntryOperator
Google

Creates an entry.

OperatorsUpdated 14 days ago
S3ToGCSOperator
Google

Synchronizes an S3 key, possibly a prefix, with a Google Cloud Storage destination path.

TransfersUpdated 14 days ago
PubSubPullSensor
Google

Pulls messages from a PubSub subscription and passes them through XCom. Always waits for at least one message to be returned from the subscription.

SensorsUpdated 14 days ago
SFTPToGCSOperator
Google

Transfer files to Google Cloud Storage from SFTP server.

TransfersUpdated 14 days ago
PubSubPublishMessageOperator
Google

Publish messages to a PubSub topic.

OperatorsUpdated 14 days ago
GoogleCampaignManagerRunReportOperator
Google

Runs a report.

OperatorsUpdated 14 days ago
PubSubCreateSubscriptionOperator
Google

Create a PubSub subscription.

OperatorsUpdated 14 days ago
PrestoToGCSOperator
Google

Copy data from PrestoDB to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
MSSQLToGCSOperator
Google

Copy data from Microsoft SQL Server to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
MLEngineTrainingCancelJobOperator
Google

Operator for cleaning up failed MLEngine training job.

OperatorsUpdated 14 days ago
MLEngineStartTrainingJobOperator
Google

Operator for launching a MLEngine training job.

OperatorsUpdated 14 days ago
PubSubPullOperator
Google

Pulls messages from a PubSub subscription and passes them through XCom. If the queue is empty, returns empty list - never waits for messages. If you d…

OperatorsUpdated 14 days ago
MLEngineListVersionsOperator
Google

Lists all available versions of the model

OperatorsUpdated 14 days ago
LevelDBOperator
Google

Execute command in LevelDB

OperatorsUpdated 14 days ago
LevelDBHookException
Google

Base class for all Airflow’s errors. Each custom exception should be derived from this class

HooksUpdated 14 days ago
PubSubHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
GoogleDriveHook
Google

Hook for the Google Drive APIs.

HooksUpdated 14 days ago
CloudDataCatalogDeleteEntryGroupOperator
Google

Deletes an EntryGroup.

OperatorsUpdated 14 days ago
CloudDataCatalogCreateTagTemplateOperator
Google

Creates a tag template.

OperatorsUpdated 14 days ago
CloudDataCatalogCreateTagTemplateFieldOperator
Google

Creates a field in a tag template.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360SDFtoGCSOperator
Google

Download SDF media and save it in the Google Cloud Storage.

OperatorsUpdated 14 days ago
GKEDeleteClusterOperator
Google

Deletes the cluster, including the Kubernetes endpoint and all worker nodes.

OperatorsUpdated 14 days ago
CloudDLPUpdateJobTriggerOperator
Google

Updates a job trigger.

OperatorsUpdated a day ago
GoogleDriveFileExistenceSensor
Google

Checks for the existence of a file in Google Cloud Storage.

SensorsUpdated 14 days ago
CloudSQLHook
Google

Hook for Google Cloud SQL APIs.

HooksUpdated 14 days ago
DataprocJobBaseOperator
Google

The base class for operators that launch job on DataProc.

OperatorsUpdated 14 days ago
DataprocJobSensor
Google

Check for the state of a previously submitted Dataproc job.

SensorsUpdated 14 days ago
DataprocScaleClusterOperator
Google

Scale, up or down, a cluster on Google Cloud Dataproc. The operator will wait until the cluster is re-scaled.

OperatorsUpdated 14 days ago
CloudVisionDetectTextOperator
Google

Detects Text in the image

OperatorsUpdated 14 days ago
CloudVisionGetProductOperator
Google

Gets information associated with a Product.

OperatorsUpdated 14 days ago
CloudVisionGetProductSetOperator
Google

Gets information associated with a ProductSet.

OperatorsUpdated 14 days ago
CloudVisionDetectImageSafeSearchOperator
Google

Detects Document Text in the image

OperatorsUpdated 14 days ago
GCSObjectCreateAclEntryOperator
Google

Creates a new ACL entry on the specified object.

OperatorsUpdated 14 days ago
GCSFileTransformOperator
Google

Copies data from a source GCS location to a temporary location on the local filesystem. Runs a transformation on this file as specified by the transfo…

OperatorsUpdated 14 days ago
GCSHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 6 days ago
GCSCreateBucketOperator
Google

Creates a new bucket. Google Cloud Storage uses a flat namespace, so you can’t create a bucket with a name that is already in use.

OperatorsUpdated 14 days ago
DataprocSubmitSparkSqlJobOperator
Google

Start a Spark SQL query Job on a Cloud DataProc cluster.

OperatorsUpdated 14 days ago
DataprocUpdateClusterOperator
Google

Updates a cluster in a project.

OperatorsUpdated 14 days ago
GCSBucketCreateAclEntryOperator
Google

Creates a new ACL entry on the specified bucket.

OperatorsUpdated 14 days ago
DataprocSubmitPySparkJobOperator
Google

Start a PySpark Job on a Cloud DataProc cluster.

OperatorsUpdated 14 days ago
DataprocSubmitPigJobOperator
Google

Start a Pig query Job on a Cloud DataProc cluster. The parameters of the operation will be passed to the cluster.

OperatorsUpdated 14 days ago
DataprocSubmitHiveJobOperator
Google

Start a Hive query Job on a Cloud DataProc cluster.

OperatorsUpdated 14 days ago
CloudVisionUpdateProductOperator
Google

Makes changes to a Product resource. Only the display_name, description, and labels fields can be updated right now.

OperatorsUpdated 14 days ago
CloudVisionTextDetectOperator
Google

Detects Document Text in the image

OperatorsUpdated 14 days ago
CloudVisionImageAnnotateOperator
Google

Run image detection and annotation for an image or a batch of images.

OperatorsUpdated 14 days ago
DataprepGetJobsForJobGroupOperator
Google

Get information about the batch jobs within a Cloud Dataprep job. API documentation https://clouddataprep.com/documentation/api#section/Overview

OperatorsUpdated 8 months ago
CloudVisionHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudVisionCreateProductOperator
Google

Creates and returns a new product resource.

OperatorsUpdated 14 days ago
CloudVideoIntelligenceHook
Google

Hook for Google Cloud Video Intelligence APIs.

HooksUpdated 14 days ago
CloudVideoIntelligenceDetectVideoLabelsOperator
Google

Performs video annotation, annotating video labels.

OperatorsUpdated 14 days ago
CloudTranslateHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudTasksTaskGetOperator
Google

Gets a task from Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTranslateSpeechOperator
Google

Recognizes speech in audio input and translates it.

OperatorsUpdated 14 days ago
CloudTranslateTextOperator
Google

Translate a string or list of strings.

OperatorsUpdated 14 days ago
CloudTasksTaskRunOperator
Google

Forces to run a task in Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTasksQueuesListOperator
Google

Lists queues from Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTasksQueueUpdateOperator
Google

Updates a queue in Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTasksTaskCreateOperator
Google

Creates a task in Cloud Tasks.

OperatorsUpdated 14 days ago
CloudTasksHook
Google

Hook for Google Cloud Tasks APIs. Cloud Tasks allows developers to manage the execution of background work in their applications.

HooksUpdated 14 days ago
CloudTasksQueueResumeOperator
Google

Resumes a queue in Cloud Tasks.

OperatorsUpdated 14 days ago
CloudSpeechToTextHook
Google

Hook for Google Cloud Speech API.

HooksUpdated 14 days ago
CloudSQLPatchInstanceDatabaseOperator
Google

Updates a resource containing information about a database inside a Cloud SQL instance using patch semantics. See: https://cloud.google.com/sql/docs/m…

OperatorsUpdated 14 days ago
CloudNaturalLanguageClassifyTextOperator
Google

Classifies a document into categories.

OperatorsUpdated 14 days ago
CloudNaturalLanguageAnalyzeSentimentOperator
Google

Analyzes the sentiment of the provided text.

OperatorsUpdated 14 days ago
CloudNaturalLanguageAnalyzeEntitySentimentOperator
Google

Finds entities, similar to AnalyzeEntities in the text and analyzes sentiment associated with each entity and its mentions.

OperatorsUpdated 14 days ago
CloudMemorystoreMemcachedCreateInstanceOperator
Google

Creates a Memcached instance based on the specified tier and memory size.

OperatorsUpdated 14 days ago
CloudMemorystoreListInstancesOperator
Google

Lists all Redis instances owned by a project in either the specified location (region) or all locations.

OperatorsUpdated 14 days ago
CloudMemorystoreImportOperator
Google

Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.

OperatorsUpdated 14 days ago
CloudMemorystoreCreateInstanceOperator
Google

Creates a Redis instance based on the specified tier and memory size.

OperatorsUpdated 14 days ago
CloudFunctionInvokeFunctionOperator
Google

Invokes a deployed Cloud Function. To be used for testing purposes as very limited traffic is allowed.

OperatorsUpdated 9 days ago
CloudDataTransferServiceResumeOperationOperator
Google

Resumes a transfer operation in Google Storage Transfer Service.

OperatorsUpdated 6 days ago
WorkflowExecutionSensor
Google

Checks state of an execution for the given workflow_id and execution_id.

SensorsUpdated 14 days ago
WorkflowsCancelExecutionOperator
Google

Cancels an execution using the given workflow_id and execution_id.

OperatorsUpdated 14 days ago
WorkflowsCreateWorkflowOperator
Google

Creates a new workflow. If a workflow with the specified name already exists in the specified project and location, the long running operation will re…

OperatorsUpdated 14 days ago
WorkflowsCreateExecutionOperator
Google

Creates a new execution using the latest revision of the given workflow.

OperatorsUpdated 14 days ago
WorkflowsDeleteWorkflowOperator
Google

Deletes a workflow with the specified name. This method also cancels and deletes all running executions of the workflow.

OperatorsUpdated 14 days ago
StackdriverHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
StackdriverEnableNotificationChannelsOperator
Google

Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.

OperatorsUpdated 14 days ago
StackdriverEnableAlertPoliciesOperator
Google

Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.

OperatorsUpdated 14 days ago
StackdriverDeleteNotificationChannelOperator
Google

Deletes a notification channel.

OperatorsUpdated 14 days ago
SpannerQueryDatabaseInstanceOperator
Google

Executes an arbitrary DML query (INSERT, UPDATE, DELETE).

OperatorsUpdated 14 days ago
StackdriverDeleteAlertOperator
Google

Deletes an alerting policy.

OperatorsUpdated 14 days ago
SpannerDeployDatabaseInstanceOperator
Google

Creates a new Cloud Spanner database, or if database exists, the operator does nothing.

OperatorsUpdated 14 days ago
PostgresToGCSOperator
Google

Copy data from Postgres to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
PubSubCreateTopicOperator
Google

Create a PubSub topic.

OperatorsUpdated 14 days ago
MLEngineSetDefaultVersionOperator
Google

Sets a version in the model.

OperatorsUpdated 14 days ago
MLEngineHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
MLEngineManageModelOperator
Google

Operator for managing a Google Cloud ML Engine model.

OperatorsUpdated 14 days ago
OSLoginHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
MLEngineManageVersionOperator
Google

Operator for managing a Google Cloud ML Engine version.

OperatorsUpdated 14 days ago
LifeSciencesRunPipelineOperator
Google

Runs a Life Sciences Pipeline

OperatorsUpdated 14 days ago
CloudVisionDetectImageLabelsOperator
Google

Detects Document Text in the image

OperatorsUpdated 14 days ago
CloudVisionDeleteReferenceImageOperator
Google

Deletes a ReferenceImage ID resource.

OperatorsUpdated 14 days ago
CloudVisionDeleteProductOperator
Google

Permanently deletes a product and its reference images.

OperatorsUpdated 14 days ago
CloudVisionCreateReferenceImageOperator
Google

Creates and returns a new ReferenceImage ID resource.

OperatorsUpdated 14 days ago
OracleToGCSOperator
Google

Copy data from Oracle to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
CloudDataCatalogDeleteTagTemplateOperator
Google

Deletes a tag template and all tags using the template.

OperatorsUpdated 14 days ago
CloudVisionDeleteProductSetOperator
Google

Permanently deletes a ProductSet. Products and ReferenceImages in the ProductSet are not deleted. The actual image files are not deleted from Google C…

OperatorsUpdated 14 days ago
PubSubDeleteSubscriptionOperator
Google

Delete a PubSub subscription.

OperatorsUpdated 14 days ago
StackdriverUpsertNotificationChannelOperator
Google

Creates a new notification or updates an existing notification channel identified the name field in the alerts parameter.

OperatorsUpdated 14 days ago
MLEngineStartBatchPredictionJobOperator
Google

Start a Google Cloud ML Engine prediction job.

OperatorsUpdated 14 days ago
MySQLToGCSOperator
Google

Copy data from MySQL to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 14 days ago
SpannerUpdateDatabaseInstanceOperator
Google

Updates a Cloud Spanner database with the specified DDL statement.

OperatorsUpdated 14 days ago
MLEngineGetModelOperator
Google

Gets a particular model

OperatorsUpdated 14 days ago
MLEngineDeleteVersionOperator
Google

Deletes the version from the model.

OperatorsUpdated 14 days ago
MLEngineDeleteModelOperator
Google

Deletes a model.

OperatorsUpdated 14 days ago
MLEngineCreateVersionOperator
Google

Creates a new version in the model

OperatorsUpdated 14 days ago
GoogleDisplayVideo360UploadLineItemsOperator
Google

Uploads line items in CSV format.

OperatorsUpdated 14 days ago
SpannerDeleteInstanceOperator
Google

Deletes a Cloud Spanner instance. If an instance does not exist, no action is taken and the operator succeeds.

OperatorsUpdated 14 days ago
GoogleDisplayVideo360RunReportOperator
Google

Runs a stored query to generate a report.

OperatorsUpdated 14 days ago
DataflowJobStatusSensor
Google

Checks for the status of a job in Google Cloud Dataflow.

SensorsUpdated 14 days ago
ComputeEngineStopInstanceOperator
Google

Stops an instance in Google Compute Engine.

OperatorsUpdated 14 days ago
ComputeEngineStartInstanceOperator
Google

Starts an instance in Google Compute Engine.

OperatorsUpdated 14 days ago
CloudVisionUpdateProductSetOperator
Google

Makes changes to a ProductSet resource. Only display_name can be updated currently.

OperatorsUpdated 14 days ago
DataprepGetJobGroupOperator
Google

Get the specified job group. A job group is a job that is executed from a specific node in a flow. API documentation https://clouddataprep.com/documen…

OperatorsUpdated 14 days ago
ComputeEngineSetMachineTypeOperator
Google

the request.

OperatorsUpdated 14 days ago
SecretsManagerHook
Google

Hook for the Google Secret Manager API.

HooksUpdated 14 days ago
SpannerHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
SalesforceToGcsOperator
Google

Submits Salesforce query and uploads results to Google Cloud Storage

TransfersUpdated 14 days ago
StackdriverDisableNotificationChannelsOperator
Google

Disables one or more enabled notification channels identified by filter parameter. Inoperative in case the policy is already disabled.

OperatorsUpdated 14 days ago
CloudDataCatalogGetEntryGroupOperator
Google

Gets an entry group.

OperatorsUpdated 14 days ago
PubSubDeleteTopicOperator
Google

Delete a PubSub topic.

OperatorsUpdated 14 days ago
LifeSciencesHook
Google

Hook for the Google Cloud Life Sciences APIs.

HooksUpdated 14 days ago
GoogleSheetsCreateSpreadsheetOperator
Google

Creates a new spreadsheet.

OperatorsUpdated 14 days ago
LevelDBHook
Google

Abstract base class for hooks, hooks are meant as an interface to interact with external systems. MySqlHook, HiveHook, PigHook return object that can …

HooksUpdated 14 days ago
GoogleSearchAdsDownloadReportOperator
Google

Downloads a report to GCS bucket.

OperatorsUpdated 14 days ago
GoogleSearchAdsReportSensor
Google

Polls for the status of a report request.

SensorsUpdated 14 days ago
GoogleDriveToGCSOperator
Google

Writes a Google Drive file into Google Cloud Storage.

TransfersUpdated 14 days ago
CloudFirestoreHook
Google

Hook for the Google Firestore APIs.

HooksUpdated 14 days ago
CloudDataCatalogDeleteTagTemplateFieldOperator
Google

Deletes a field in a tag template and all uses of that field.

OperatorsUpdated 14 days ago
GoogleSearchAdsInsertReportOperator
Google

Inserts a report request into the reporting system.

OperatorsUpdated 14 days ago
GcpTransferOperationStatus
Google

Class with Google Cloud Transfer operations statuses.

Hooks
BaseSQLToGCSOperator
Google

Copy data from SQL to Google Cloud Storage in JSON or CSV format.

TransfersUpdated 9 days ago
BigQueryUpdateTableSchemaOperator
Google

Update BigQuery Table Schema Updates fields on a table schema based on contents of the supplied schema_fields_updates parameter. The supplied schema d…

OperatorsUpdated 7 days ago
BigQueryToMsSqlOperator
Google

Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and insert that data into a MSSQL table.

TransfersUpdated 14 days ago
CloudDataFusionPipelineStateSensor
Google

Check the status of the pipeline in the Google Cloud Data Fusion

SensorsUpdated 14 days ago
SQLToGoogleSheetsOperator
Google

Copy data from SQL results to provided Google Spreadsheet.

TransfersUpdated 14 days ago
CloudBuildUpdateBuildTriggerOperator
Google

Updates a BuildTrigger by its project ID and trigger ID.

OperatorsUpdated 14 days ago
CloudBuildListBuildTriggersOperator
Google

Lists existing BuildTriggers.

OperatorsUpdated 14 days ago
CloudBuildGetBuildOperator
Google

Returns information about a previously requested build.

OperatorsUpdated 14 days ago
CloudBuildGetBuildTriggerOperator
Google

Returns information about a BuildTrigger.

OperatorsUpdated 14 days ago
CloudBuildListBuildsOperator
Google

Lists previously requested builds.

OperatorsUpdated 14 days ago
CloudBuildRetryBuildOperator
Google

Creates a new build based on the specified build. This method creates a new build using the original build request, which may or may not result in an …

OperatorsUpdated 14 days ago
CloudBuildRunBuildTriggerOperator
Google

Runs a BuildTrigger at a particular source revision.

OperatorsUpdated 14 days ago
CloudBuildCreateBuildTriggerOperator
Google

Creates a new BuildTrigger.

OperatorsUpdated 14 days ago
CloudBuildDeleteBuildTriggerOperator
Google

Deletes a BuildTrigger by its project ID and trigger ID.

OperatorsUpdated 14 days ago
CloudBuildCancelBuildOperator
Google

Cancels a build in progress.

OperatorsUpdated 14 days ago
DataprocMetastoreListBackupsOperator
Google

Lists backups in a service.

OperatorsUpdated 14 days ago
DataprocMetastoreExportMetadataOperator
Google

Exports metadata from a service.

OperatorsUpdated 14 days ago
DataprocMetastoreRestoreServiceOperator
Google

Restores a service from a backup.

OperatorsUpdated 14 days ago
DataprocMetastoreHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
DataprocMetastoreUpdateServiceOperator
Google

Updates the parameters of a single service.

OperatorsUpdated 14 days ago
DataprocMetastoreDeleteBackupOperator
Google

Deletes a single backup.

OperatorsUpdated 14 days ago
DataprocMetastoreGetServiceOperator
Google

Gets the details of a single service.

OperatorsUpdated 14 days ago
DataprocMetastoreCreateServiceOperator
Google

Creates a metastore service in a project and location.

OperatorsUpdated 14 days ago
DataprocMetastoreCreateBackupOperator
Google

Creates a new backup in a given project and location.

OperatorsUpdated 14 days ago
DataprocListBatchesOperator
Google

Lists batch workloads.

OperatorsUpdated 14 days ago
DataprocGetBatchOperator
Google

Gets the batch workload resource representation.

OperatorsUpdated 14 days ago
DataprocMetastoreCreateMetadataImportOperator
Google

Creates a new MetadataImport in a given project and location.

OperatorsUpdated 14 days ago
DataprocDeleteBatchOperator
Google

Deletes the batch workload resource.

OperatorsUpdated 14 days ago
DataprocCreateBatchOperator
Google

Creates a batch workload.

OperatorsUpdated 14 days ago
DataprocMetastoreDeleteServiceOperator
Google

Deletes a single service.

OperatorsUpdated 14 days ago
GoogleCalendarHook
Google

Interact with Google Calendar via Google Cloud connection Reading and writing cells in Google Sheet: https://developers.google.com/calendar/api/v3/ref…

HooksUpdated 14 days ago
CloudComposerListImageVersionsOperator
Google

List ImageVersions for provided location.

OperatorsUpdated 14 days ago
CloudComposerListEnvironmentsOperator
Google

List environments.

OperatorsUpdated 14 days ago
CloudComposerUpdateEnvironmentOperator
Google

Update an environment.

OperatorsUpdated 14 days ago
CloudComposerGetEnvironmentOperator
Google

Get an existing environment.

OperatorsUpdated 14 days ago
CloudComposerHook
Google

A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…

HooksUpdated 14 days ago
CloudComposerDeleteEnvironmentOperator
Google

Delete an environment.

OperatorsUpdated 14 days ago
CloudComposerCreateEnvironmentOperator
Google

Create a new environment.

OperatorsUpdated 14 days ago
CloudComposerExecutionTrigger
Google

Base class for all triggers.

TriggersUpdated 14 days ago
LookerStartPdtBuildOperator
Google

Submits a PDT materialization job to Looker.

OperatorsUpdated 14 days ago
GoogleCalendarToGCSOperator
Google

Writes Google Calendar data into Google Cloud Storage.

TransfersUpdated 14 days ago
LookerHook
Google

Abstract base class for hooks, hooks are meant as an interface to interact with external systems. MySqlHook, HiveHook, PigHook return object that can …

HooksUpdated 14 days ago
LookerCheckPdtBuildSensor
Google

Check for the state of a previously submitted PDT materialization job.

SensorsUpdated 14 days ago
LocalFilesystemToGoogleDriveOperator
Google

Upload a list of files to a Google Drive folder. This operator uploads a list of local files to a Google Drive folder. The local files can be deleted …

TransfersUpdated 14 days ago
DataplexListTasksOperator
Google

Lists tasks under the given lake.

OperatorsUpdated 14 days ago
DataplexTaskStateSensor
Google

Check the status of the Dataplex task

SensorsUpdated 14 days ago
DataplexCreateTaskOperator
Google

Creates a task resource within a lake.

OperatorsUpdated 14 days ago
DataplexGetTaskOperator
Google

Get task resource.

OperatorsUpdated 14 days ago
DataplexHook
Google

Hook for Google Dataplex.

HooksUpdated 14 days ago
DataplexDeleteTaskOperator
Google

Delete the task resource.

OperatorsUpdated 14 days ago
ADLSToGCSOperator
Google

Synchronizes an Azure Data Lake Storage path with a GCS bucket

TransfersUpdated 14 days ago