Skip to content

update(snowflake): Separate Streaming connector and sink #3118

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: release-6.0
Choose a base branch
from

Conversation

Meggielqk
Copy link
Collaborator

No description provided.

@Meggielqk Meggielqk added this to the 6.0.0 milestone Aug 11, 2025
@Meggielqk Meggielqk requested review from Copilot and lina50 August 12, 2025 03:19
Copy link
Contributor

@Copilot Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull Request Overview

This PR separates the Snowflake integration documentation by splitting the single connector approach into two distinct connector types: one for aggregated mode and another for streaming mode. This change improves clarity by providing dedicated setup instructions for each upload method.

  • Replaces unified Snowflake connector configuration with separate Snowflake and Snowflake Streaming connectors
  • Restructures the Sink creation process to clearly distinguish between aggregated and streaming upload modes
  • Updates section organization to provide clearer step-by-step guidance for each mode

Reviewed Changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 1 comment.

File Description
zh_CN/data-integration/snowflake.md Chinese documentation update separating connector types and reorganizing Sink configuration sections
en_US/data-integration/snowflake.md English documentation update with identical structural changes to match Chinese version

@Meggielqk Meggielqk requested a review from thalesmg August 12, 2025 03:19
@Meggielqk Meggielqk marked this pull request as ready for review August 12, 2025 03:20
- **Server Host**: The server host is the Snowflake endpoint URL, typically in the format `<Your Snowflake Organization ID>-<Your Snowflake Account Name>.snowflakecomputing.com`. You need to replace `<Your Snowflake Organization ID>-<Your Snowflake Account Name>` with the subdomain specific to your Snowflake instance.
- **Username**: (Optional) Enter the Snowflake user with a registered RSA public key if you configured it in `odbc.ini` (e.g. `snowpipeuser`).
- **Account**: Enter your Snowflake Organization ID and Snowflake account name separated by a dash (`-`), which is part of the URL you use to access the Snowflake platform and can be found in your Snowflake console.
- **Pipe User**: The name of a Snowflake user account that has a role with permissions to operate the target Pipe, for example, `snowpipeuser`. The role must have at least the `OPERATE` and `MONITOR` privileges.
- **Private Key Path**: The absolute file path to the private RSA key. EMQX uses this key to sign JWT tokens to authenticate itself with the Snowflake API. This path must be consistent across all nodes of the cluster. For example:
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For the streaming connector, this is no longer a cluster-wide path but a regular secret (i.e., can be specified inline, or point to a file containing the secret with file://)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants