高性能アーキテクチャを備えたSnowpipe Streamingの構成¶

このガイドでは、JavaおよびPython SDKs で使用できる高性能なSnowpipe Streamingクライアントの構成設定について説明します。構成には2つの異なる種類があります。

• プロセス全体の環境変数:実行中のアプリケーション全体のログとメトリックを制御する変数。クライアントが初期化される前に設定する必要があります。

• クライアント側のプロパティ:安全な接続と取り込みターゲットを定義するプロパティ（url、 user、 private_key など）は、通常インラインマップまたは profile.json ファイルを通じて、特定のクライアントオブジェクト用に構成されます。

単一のアプリケーションで複数のクライアントオブジェクトを実行できます。各オブジェクトは独自のクライアント側プロパティを持ちますが、ログとメトリックのためにプロセス全体の同じ環境変数設定をすべて共有します。

高性能アーキテクチャでは、スキーマ、変換、およびターゲットテーブルへの取り込みを管理する特定の PIPE オブジェクトにクライアントを明示的にバインドする必要があります。

// profile.json
{
  "authorization_type": "JWT",
  "url": "https://<account_identifier>.snowflakecomputing.com",
  "user": "MY_SNOWFLAKE_USER",
  "account": "XY12345",
  "private_key_file": "/path/to/rsa_key.p8",
  "role": "MY_INGEST_ROLE"
}

config = {
    "authorization_type": "JWT",
    "url": "https://<account_identifier>.snowflakecomputing.com",
    "user": "MY_SNOWFLAKE_USER",
    "account": "XY12345",
    "private_key": "-----BEGIN PRIVATE KEY-----\n...\n-----END PRIVATE KEY-----",
}
# ... code to initialize client with 'config'

Map<String, Object> config = new HashMap<>();
config.put("authorization_type", "JWT");
config.put("url", "https://<account_identifier>.snowflakecomputing.com");
config.put("user", "MY_SNOWFLAKE_USER");
config.put("account", "XY12345");
config.put("private_key_file", "/path/to/rsa_key.p8");
config.put("role", "MY_INGEST_ROLE");
// ... code to initialize client with 'config'

# Set the log level for the entire application process to 'warn'
export SS_LOG_LEVEL=warn

# Change the IP for metrics to a specific loopback address
export SS_METRICS_IP=127.0.0.5

# Now run your application

# Set the log level for the entire application process to 'warn'
set SS_LOG_LEVEL=warn

# Change the metrics port
set SS_METRICS_PORT=55000

# Now run your application