deltastream-connector 0.1.2

An OpenAPI client for the DeltaStream API

deltastream-connector

A Python client library for DeltaStream - a SQL streaming processing engine based on Apache Flink.

Features

• Asynchronous API client for DeltaStream
• Support for SQL statements execution
• Streaming result sets
• API Token authentication
• Python 3.11+ support

Installation

pip install deltastream-connector

Quick Start

import asyncio
from deltastream.api.conn import APIConnection

# Initialize connection with API token
conn = APIConnection.from_dsn("https://:<your_token>@api.deltastream.io/v2")

async def main():
    # Execute SQL queries
    rows = await conn.query("SELECT 1;")
    
    # Process results asynchronously
    async for row in rows:
        print(row)

if __name__ == '__main__':
    asyncio.run(main())

Authentication

The connector uses API token authentication. You can obtain an API token from the DeltaStream platform by running CREATE API_TOKEN api_token_name; using the console.

Support

For support, please contact [e-mail] or open an issue on our GitHub repository.