diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | python-aioch.spec | 288 | ||||
| -rw-r--r-- | sources | 1 |
3 files changed, 290 insertions, 0 deletions
@@ -0,0 +1 @@ +/aioch-0.0.2.tar.gz diff --git a/python-aioch.spec b/python-aioch.spec new file mode 100644 index 0000000..417d10b --- /dev/null +++ b/python-aioch.spec @@ -0,0 +1,288 @@ +%global _empty_manifest_terminate_build 0 +Name: python-aioch +Version: 0.0.2 +Release: 1 +Summary: Library for accessing a ClickHouse database over native interface from the asyncio +License: MIT +URL: https://github.com/mymarilyn/aioch +Source0: https://mirrors.nju.edu.cn/pypi/web/packages/3c/1b/65c9e14966a940bcf5afa72a16f9e3924c815ba8fca8c0e133b20c73f697/aioch-0.0.2.tar.gz +BuildArch: noarch + + +%description +# aioch +**aioch** is a library for accessing a ClickHouse database over native interface from the asyncio. +It wraps features of [clickhouse-driver](https://github.com/mymarilyn/clickhouse-driver) for asynchronous usage. + +[](https://coveralls.io/github/mymarilyn/aioch?branch=master) +[](https://travis-ci.org/mymarilyn/aioch) + + +## Installation + +The package can be installed using `pip`: + +```bash +pip install aioch +``` + +To install from source: + +```bash +git clone https://github.com/mymarilyn/aioch +cd aioch +python setup.py install +``` + +## Usage +```python +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](http://www.opensource.org/licenses/mit-license.php). + +%package -n python3-aioch +Summary: Library for accessing a ClickHouse database over native interface from the asyncio +Provides: python-aioch +BuildRequires: python3-devel +BuildRequires: python3-setuptools +BuildRequires: python3-pip +%description -n python3-aioch +# aioch +**aioch** is a library for accessing a ClickHouse database over native interface from the asyncio. +It wraps features of [clickhouse-driver](https://github.com/mymarilyn/clickhouse-driver) for asynchronous usage. + +[](https://coveralls.io/github/mymarilyn/aioch?branch=master) +[](https://travis-ci.org/mymarilyn/aioch) + + +## Installation + +The package can be installed using `pip`: + +```bash +pip install aioch +``` + +To install from source: + +```bash +git clone https://github.com/mymarilyn/aioch +cd aioch +python setup.py install +``` + +## Usage +```python +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](http://www.opensource.org/licenses/mit-license.php). + +%package help +Summary: Development documents and examples for aioch +Provides: python3-aioch-doc +%description help +# aioch +**aioch** is a library for accessing a ClickHouse database over native interface from the asyncio. +It wraps features of [clickhouse-driver](https://github.com/mymarilyn/clickhouse-driver) for asynchronous usage. + +[](https://coveralls.io/github/mymarilyn/aioch?branch=master) +[](https://travis-ci.org/mymarilyn/aioch) + + +## Installation + +The package can be installed using `pip`: + +```bash +pip install aioch +``` + +To install from source: + +```bash +git clone https://github.com/mymarilyn/aioch +cd aioch +python setup.py install +``` + +## Usage +```python +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](http://www.opensource.org/licenses/mit-license.php). + +%prep +%autosetup -n aioch-0.0.2 + +%build +%py3_build + +%install +%py3_install +install -d -m755 %{buildroot}/%{_pkgdocdir} +if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi +if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi +if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi +if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi +pushd %{buildroot} +if [ -d usr/lib ]; then + find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/lib64 ]; then + find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/bin ]; then + find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/sbin ]; then + find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst +fi +touch doclist.lst +if [ -d usr/share/man ]; then + find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst +fi +popd +mv %{buildroot}/filelist.lst . +mv %{buildroot}/doclist.lst . + +%files -n python3-aioch -f filelist.lst +%dir %{python3_sitelib}/* + +%files help -f doclist.lst +%{_docdir}/* + +%changelog +* Tue Apr 11 2023 Python_Bot <Python_Bot@openeuler.org> - 0.0.2-1 +- Package Spec generated @@ -0,0 +1 @@ +70c26dbe5199c4034d47c8c327cb9adf aioch-0.0.2.tar.gz |