Tutorial: Erste Schritte mit der leistungsstarken Snowpipe Streaming-Architektur SDK¶

Voraussetzungen¶

Bevor Sie die Demo ausführen, stellen Sie sicher, dass Sie die folgenden Voraussetzungen erfüllen:

• Snowflake-Konto: Vergewissern Sie sich, dass Sie Zugriff auf ein Snowflake-Konto haben. Sie benötigen einen Benutzer mit ausreichenden Berechtigungen (z. B. ACCOUNTADMIN oder USERADMIN für die Ersteinrichtung), um den dedizierten Benutzer und die kundenspezifische Rolle zu erstellen, die unter Schritt 1: Konfigurieren Sie Snowflake-Objekte beschrieben sind.

• Netzwerkzugriff: Stellen Sie sicher, dass Ihr Netzwerk ausgehende Konnektivität zu Snowflake und Amazon S3 oder Google Cloud Platform (GCS) oder Azure Blob Storage zulässt. Passen Sie die Firewall-Regeln falls erforderlich an, da die SDK REST API-Aufrufe an Snowflake und an Ihren Cloudspeicheranbieter tätigt.

  • Um die Konnektivität mit dem Netzwerk zu überprüfen, verwenden Sie den folgenden Befehl:

  CopyExpand

  # Test connectivity to Snowflake; replace with your account URL
  curl -I https://<your_account_identifier>.snowflakecomputing.com
  
  # Test connectivity to AWS S3
  curl -I https://s3.amazonaws.com
  
  # Test connectivity to GCS
  curl -I https://storage.googleapis.com
  
  # Test connectivity to Azure Blob Storage
  curl -I https://azure.blob.core.windows.net  or curl -I https://<your_account_name>.blob.core.windows.net
  

  Show lessSee more

  Scroll to top

• Java-Entwicklungsumgebung Installieren Sie Java 11 oder höher und Maven für die Verwaltung von Abhängigkeiten.

• Python: Erfordert Python Version 3.9 oder höher.

• Systemanforderungen: Das SDK erfordert glibc-Version 2.26 oder höher. Sie können Ihre aktuelle glibc-Version wie folgt überprüfen:

  CopyExpand

  ldd --version
  

  Show lessSee more

  Scroll to top

• Snowpipe Streaming SDKs und der Beispielcode:

  • Für AWS: Beziehen Sie das Java SDK oder Python SDK (beliebige Version).

  • Für Azure: Erfordert SDK Version 1.1.0 oder höher.

  • Für GCP: Erfordert SDK Version 1.1.0 oder höher.

  Laden Sie den Beispielcode für Ihre bevorzugte Sprache aus den Snowpipe Streaming SDK-Beispielen im GitHub-Repository herunter.

Erste Schritte¶

In diesem Abschnitt werden die Schritte beschrieben, die zur Einrichtung und Ausführung der Demo-Anwendung erforderlich sind.

openssl genrsa 2048 | openssl pkcs8 -topk8 -inform PEM -out rsa_key.p8 -nocrypt
openssl rsa -in rsa_key.p8 -pubout -out rsa_key.pub

PUBK=$(cat ./rsa_key.pub | grep -v KEY- | tr -d '\012')
echo "ALTER USER MY_USER SET RSA_PUBLIC_KEY='$PUBK';"

-- 1. Create a dedicated role and user (Run with a highly-privileged role)
CREATE OR REPLACE USER MY_USER;
CREATE ROLE IF NOT EXISTS MY_ROLE;
GRANT ROLE MY_ROLE TO USER MY_USER;

-- 2. Set the public key for key-pair authentication
-- NOTE: Replace 'YOUR_FORMATTED_PUBLIC_KEY' with the output of the PUBK variable from the key generation step.
ALTER USER MY_USER SET RSA_PUBLIC_KEY='YOUR_FORMATTED_PUBLIC_KEY';

-- 3. Set the default role (Recommended)
ALTER USER MY_USER SET DEFAULT_ROLE=MY_ROLE;

-- 4. Switch to the new role and create objects
USE ROLE MY_ROLE;
-- NOTE: You may also need to run USE WAREHOUSE YOUR_WH; here if a default warehouse isn't set.

-- Create database and schema
CREATE OR REPLACE DATABASE MY_DATABASE;
CREATE OR REPLACE SCHEMA MY_SCHEMA;

-- Create a target table
CREATE OR REPLACE TABLE MY_TABLE (
    data VARIANT,
    c1 NUMBER,
    c2 STRING
);

-- 5. Configure authentication policy (Optional, but recommended for explicit control)
CREATE OR REPLACE AUTHENTICATION POLICY testing_auth_policy
  AUTHENTICATION_METHODS = ('KEYPAIR')
  CLIENT_TYPES = ('DRIVERS');

-- Apply authentication policy (if created)
ALTER USER MY_USER SET AUTHENTICATION POLICY testing_auth_policy;

{
    "user": "MY_USER",
    "account": "your_account_identifier",
    "url": "https://your_account_identifier.snowflakecomputing.com:443",
    "private_key_file": "rsa_key.p8",
    "role": "MY_ROLE"
}

<dependency>
    <groupId>com.snowflake</groupId>
    <artifactId>snowpipe-streaming</artifactId>
    <version>YOUR_SDK_VERSION</version>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.18.1</version>
</dependency>

pip install snowpipe-streaming

python example.py

SELECT COUNT(*) FROM MY_DATABASE.MY_SCHEMA.MY_TABLE;
SELECT * FROM MY_DATABASE.MY_SCHEMA.MY_TABLE LIMIT 10;

SELECT
    data,
    TYPEOF(data) as data_type
FROM MY_DATABASE.MY_SCHEMA.MY_TABLE
LIMIT 10;