Skip to main content

postgres_forward_etl

Creates, updates, deletes, gets or lists a postgres_forward_etl resource.

Overview

Namepostgres_forward_etl
TypeResource
Iddatabricks_workspace.postgres.postgres_forward_etl

Fields

The following fields are returned by SELECT queries:

NameDatatypeDescription
configurationsarrayList of Forward ETL configurations.
table_mappingsarrayPer-table replication mappings.

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
getselectparent, deployment_nametenant_id, timeline_idGet Forward ETL configuration and status for a branch.
disabledeleteparent, deployment_namepg_database_oid, pg_schema_oid, tenant_id, timeline_idDisable Forward ETL for a branch.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

NameDatatypeDescription
deployment_namestringThe Databricks Workspace Deployment Name (default: dbc-abcd0123-a1bc)
parentstringThe Branch to disable Forward ETL for. Format: projects/{project_id}/branches/{branch_id}
pg_database_oidintegerPostgreSQL database OID to disable.
pg_schema_oidintegerPostgreSQL schema OID to disable.
tenant_idstringTenant ID (dashless UUID format).
timeline_idstringTimeline ID (dashless UUID format).

SELECT examples

Get Forward ETL configuration and status for a branch.

SELECT
configurations,
table_mappings
FROM databricks_workspace.postgres.postgres_forward_etl
WHERE parent = '{{ parent }}' -- required
AND deployment_name = '{{ deployment_name }}' -- required
AND tenant_id = '{{ tenant_id }}'
AND timeline_id = '{{ timeline_id }}'
;

DELETE examples

Disable Forward ETL for a branch.

DELETE FROM databricks_workspace.postgres.postgres_forward_etl
WHERE parent = '{{ parent }}' --required
AND deployment_name = '{{ deployment_name }}' --required
AND pg_database_oid = '{{ pg_database_oid }}'
AND pg_schema_oid = '{{ pg_schema_oid }}'
AND tenant_id = '{{ tenant_id }}'
AND timeline_id = '{{ timeline_id }}'
;