Snowflake connector

Union.ai can be seamlessly integrated with the Snowflake service, providing you with a straightforward means to query data in Snowflake.

Installation

To use the Snowflake connector, run the following command:

$ pip install flytekitplugins-snowflake

Example usage

For an example query, see Snowflake connector example usage

Local testing

To test the Snowflake connector locally, create a class for the connector task that inherits from AsyncConnectorExecutorMixin. This mixin can handle asynchronous tasks and allows the SDK to mimic the system’s behavior in calling the connector.

For more information, see Testing connectors locally.

In some cases, you will need to store credentials in your local environment when testing locally.