GitLocker: The Coding Marketplace

Description:

aioclickhouse 0.0.5

aioch
aioch is a library for accessing a ClickHouse database over native interface from the asyncio.
It wraps features of clickhouse-driver for asynchronous usage.
Installation
The package can be installed using pip:
pip install aioclickhouse

Usage
from datetime import datetime

import asyncio
from aioch import Client

async def exec_progress():
client = Client('localhost')

progress = await client.execute_with_progress('LONG AND COMPLICATED QUERY')
timeout = 20
started_at = datetime.now()

async for num_rows, total_rows in progress:
done = num_rows / total_rows if total_rows else total_rows
now = datetime.now()
# Cancel query if it takes more than 20 seconds to process 50% of rows.
if (now - started_at).total_seconds() > timeout and done < 0.5:
await client.cancel()
break
else:
rv = await progress.get_result()
print(rv)

async def exec_no_progress():
client = Client('localhost')
rv = await client.execute('LONG AND COMPLICATED QUERY')
print(rv)

loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait([exec_progress(), exec_no_progress()]))

For more information see clickhouse-driver usage examples.
Parameters

executor - instance of custom Executor, if not supplied default executor will be used
loop - asyncio compatible event loop

Other parameters are passing to wrapped clickhouse-driver's Client.
License
aioch is distributed under the MIT license.