Snowflake CDC Account

Overview

Use this account type to connect Snowflake CDC Snaps with data sources that use Snowflake CDC accounts.

Prerequisites

  • Configure Snowflake Streams on the source tables.
  • Grant the account role access to the database, schema, tables, and streams.
  • Create the streams before running the pipeline.

Account settings


Snowflake CDC account settings
Field/Field set Type Description
Label*

String

Specify a unique label for the account.

Default value: N/A

Example: Snowflake CDC Account
Account*

String/Expression

 Specify your Snowflake account identifier.

Default value: N/A

Example: UGWDNММ-SO41235
Username*

String/Expression

 Specify the Snowflake user name used to connect to the account.

Default value: N/A

Example: SNOWFLAKE_USER
Password*

String/Expression

 Specify the password for the Snowflake user.

Default value: N/A

Example: Password123
Warehouse

String/Expression

 Required. Specify the Snowflake warehouse to use for query execution.

Default value: N/A

Example: COMPUTE_WH
Database

String/Expression

 Required. Specify the Snowflake database that contains the source tables and streams.

Default value: N/A

Example: HR_DB
Schema

String/Expression

 Required. Specify the schema that contains the source tables and streams.

Default value: N/A

Example: PUBLIC
Role

String/Expression

 Specify the Snowflake role to use for the session. The role must have access to the warehouse, database, schema, source tables, and streams.

Default value: N/A

Example: CDC_ADMIN

Troubleshooting

Error Reason Resolution
Authentication failed Invalid credentials or insufficient permissions. Verify that the username, password, and account identifier are correct and that the account has appropriate permissions to access Snowflake Streams.
Stream not found The specified stream does not exist in the schema. Verify that the Snowflake Stream has been created on the source table before running the pipeline.
Insufficient privileges The role does not have the required permissions to access the stream or tables. Grant the account role access to the database, schema, tables, and streams. Ensure the role has SELECT privileges on the stream.