Registry / database / snowpipe-streaming

snowpipe-streaming

library1.5.0pypypiunverified

Snowpipe Streaming is a Python SDK for ingesting data into Snowflake tables in near-real-time using the Snowflake Ingest SDK. It provides high-throughput streaming ingestion via the Snowpipe Streaming REST API. Current version 1.5.0, requires Python >=3.9. Released monthly.

database

pip install snowpipe-streaming

github ↗homepage ↗

INSTALL

IMPORT

SIG · SNOWPIPE-STREAMING

snowpipe-streaming

databasepythonv1.5.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

SnowflakeConnector

✓ from snowflake.ingest import SnowflakeConnector

✗ from snowflake.ingest import SnowflakeConnector

Basic usage: create a connector, connect, insert files, and disconnect.

from snowflake.ingest import SnowflakeConnector connector = SnowflakeConnector( account="my_account", user="my_user", private_key="my_private_key", role="sysadmin" ) connector.connect() # Insert a file connector.insert_files(["file.parquet"], database="MYDB", schema="PUBLIC", table="MYTABLE") connector.disconnect()

Debug

Known issues

breakingAuthentication changed in v1.2.0: private_key must be a PEM string, not a file path.

fix

Read the private key from file and pass as string: open('key.p8').read()

affects: >=1.2.0

gotchaThe package name is 'snowpipe-streaming' but the import uses 'snowflake.ingest'.

fix

Use `from snowflake.ingest import SnowflakeConnector`.

affects: all

deprecatedMethod `insert_file` is deprecated in v1.4.0 in favor of `insert_files` with list argument.

fix

Use `insert_files([file_path])` instead of `insert_file(file_path)`.

affects: 1.4.0+

Upgrade

Version history

1.5.0latest on PyPI · released May 20, 2026

Audit

Dependencies

No dependency data recorded yet.

Agent activity

23 hits · last 30 days

node