aio-clickhouse 0.0.5

Creator: railscoder56

Last updated:

0 purchases

aio-clickhouse 0.0.5 Image
aio-clickhouse 0.0.5 Images

Languages

Categories

Add to Cart

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.

License

For personal and professional use. You cannot resell or redistribute these repositories in their original state.

Customer Reviews

There are no reviews.