Tutorial: Erste Schritte mit dem Snowpipe Streaming High-Performance-Architektur-SDK¶

Schlüsselpaar zur Authentifizierung generieren¶

Erzeugen Sie ein Schlüsselpaar aus privatem und öffentlichem Schlüssel für die Authentifizierung mit OpenSSL. Weitere Informationen dazu finden Sie unter Schlüsselpaar-Authentifizierung und Schlüsselpaar-Rotation.

Führen Sie die folgenden Befehle in Ihrem Terminal aus, um die Schlüssel zu erzeugen:

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';"

Create database, schema, table, and configure user authentication¶

Run the following SQL commands in your Snowflake account; for example, by using Snowsight or Snowflake CLI). You must have a role with permissions to create users, roles, and databases — such as ACCOUNTADMIN or USERADMIN for the first few lines, and then switching to the new role. Replace placeholders like MY_USER, MY_ROLE, MY_DATABASE, and so on, with the names that you want.

-- 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;

Profilkonfigurationsdatei erstellen¶

Erstellen oder aktualisieren Sie die profile.json-Datei im Verzeichnis Ihres Demo-Projekts.

profile.json-Vorlage¶

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

Ersetzen Sie die Platzhalter:

• MY_USER: Ihr in Schritt 1: Konfigurieren Sie Snowflake-Objekte konfigurierter Snowflake-Benutzername.

• your_account_identifier: Ihr Snowflake-Kontobezeichner (z. B. xy12345).

• rsa_key.p8: Die private Schlüsseldatei, die Sie in Schritt 1: Konfigurieren Sie Snowflake-Objekte generiert haben.

• MY_ROLE: The dedicated role (MY_ROLE) you created and granted to the user in Schritt 1: Konfigurieren Sie Snowflake-Objekte.

Platzieren Sie die Profildatei¶

Stellen Sie sicher, dass sich die profile.json-Datei, die Sie in Schritt 2: Konfigurieren Sie ein Authentifizierungsprofil konfiguriert haben, im Stammverzeichnis Ihres Projekts befindet.