Algolia Search Asyncronous API Client for Python
Project description
[![Build Status](https://travis-ci.com/algolia/algoliasearch-client-python-async.svg?token=NAo1YMSYUe1rsBFvhGmF&branch=master)](https://travis-ci.com/algolia/algoliasearch-client-python-async)
[![PyPI version](https://badge.fury.io/py/algoliasearchasync.svg)](https://badge.fury.io/py/algoliasearchasync)
[![Coverage Status](https://coveralls.io/repos/github/algolia/algoliasearch-client-python-async/badge.svg?branch=master)](https://coveralls.io/github/algolia/algoliasearch-client-python-async?branch=master)
# Algolia Asynchronous Python Client
This package is designed to replace the
[`algoliasearch`](https://github.com/algolia/algoliasearch-client-python)
package in asynchronous environments.
This package is only compatible with python 3.4 and onward.
## What it does
- Is compatible with python `asyncio`.
- Provide asynchronous alternatives to most of the client methods.
All those methods are just suffixed by `_async` (`search_async`,
`add_object_async`, etc.)
- Still provide synchronous versions of the methods.
- Uses `aiohttp` as the HTTP underlying library.
- Uses `__aexit__` to avoid manually closing `aiohttp` sessions with
python >= 3.5.1.
## What it does **not**
- Implement the `search_disjunctive_faceting` method.
- Support task canceling (yet).
## Installation and Dependencies
Most of the logic of the synchronous client is being used here, so this
client depends on the synchronous one. It also depends on `aiohttp`.
To install this package: `pip install algoliasearchasync`.
## Documentation
All the asynchronous functions have the same names as the synchronous ones
with `_async` appended. Synchronous methods keep the same name.
Arguments taken by the asynchronous functions are the same as the synchronous
one, for documentation on the behavior of each function please see:
- [Synchronous python client](https://github.com/algolia/algoliasearch-client-python)
- [Algolia documentation](https://www.algolia.com/doc)
## Examples
With python >= 3.4
```python
import asyncio
from algoliasearchasync import ClientAsync
@asyncio.coroutine
def main(terms):
client = ClientAsync('<APP_ID>', '<API_KEY>')
index = client.init_index('<INDEX_NAME>')
# Create as many searches as there is terms.
searches = [index.search_async(term) for term in terms]
# Store the aggregated results.
s = yield from asyncio.gather(*searches)
# Client must be closed manually before exiting the program.
yield from client.close()
# Return the aggregated results.
return s
terms = ['<TERM2>', '<TERM2>']
loop = asyncio.get_event_loop()
# Start and wait for the tasks to complete.
complete = loop.run_until_complete(asyncio.gather(*searches))
for term, search in zip(terms, complete):
print('Results for: {}'.format(term))
# Display the field '<FIELD>' of each result.
print('\n'.join([h['<FIELD>'] for h in search['hits']]))
```
With python >= 3.5.1
```python
import asyncio
from algoliasearchasync import ClientAsync
# Define a coroutine to be able to use `async with`.
async def main(terms):
# Scope the client for it to be closed automatically.
async with ClientAsync('<APP_ID>', '<API_KEY>') as client:
index = client.init_index('<INDEX_NAME>')
# Create as many searches as there is terms.
searches = [index.search_async(term) for term in terms]
# Return the aggregated results.
return await asyncio.gather(*searches)
terms = ['<TERM1>', '<TERM2>']
loop = asyncio.get_event_loop()
# Start and wait for the tasks to complete.
complete = loop.run_until_complete(main(terms))
for term, search in zip(terms, complete):
print('Results for {}'.format(term))
# Display the field '<FIELD>' of each result.
print('\n'.join([h['<FIELD>'] for h in search['hits']]))
```
[![PyPI version](https://badge.fury.io/py/algoliasearchasync.svg)](https://badge.fury.io/py/algoliasearchasync)
[![Coverage Status](https://coveralls.io/repos/github/algolia/algoliasearch-client-python-async/badge.svg?branch=master)](https://coveralls.io/github/algolia/algoliasearch-client-python-async?branch=master)
# Algolia Asynchronous Python Client
This package is designed to replace the
[`algoliasearch`](https://github.com/algolia/algoliasearch-client-python)
package in asynchronous environments.
This package is only compatible with python 3.4 and onward.
## What it does
- Is compatible with python `asyncio`.
- Provide asynchronous alternatives to most of the client methods.
All those methods are just suffixed by `_async` (`search_async`,
`add_object_async`, etc.)
- Still provide synchronous versions of the methods.
- Uses `aiohttp` as the HTTP underlying library.
- Uses `__aexit__` to avoid manually closing `aiohttp` sessions with
python >= 3.5.1.
## What it does **not**
- Implement the `search_disjunctive_faceting` method.
- Support task canceling (yet).
## Installation and Dependencies
Most of the logic of the synchronous client is being used here, so this
client depends on the synchronous one. It also depends on `aiohttp`.
To install this package: `pip install algoliasearchasync`.
## Documentation
All the asynchronous functions have the same names as the synchronous ones
with `_async` appended. Synchronous methods keep the same name.
Arguments taken by the asynchronous functions are the same as the synchronous
one, for documentation on the behavior of each function please see:
- [Synchronous python client](https://github.com/algolia/algoliasearch-client-python)
- [Algolia documentation](https://www.algolia.com/doc)
## Examples
With python >= 3.4
```python
import asyncio
from algoliasearchasync import ClientAsync
@asyncio.coroutine
def main(terms):
client = ClientAsync('<APP_ID>', '<API_KEY>')
index = client.init_index('<INDEX_NAME>')
# Create as many searches as there is terms.
searches = [index.search_async(term) for term in terms]
# Store the aggregated results.
s = yield from asyncio.gather(*searches)
# Client must be closed manually before exiting the program.
yield from client.close()
# Return the aggregated results.
return s
terms = ['<TERM2>', '<TERM2>']
loop = asyncio.get_event_loop()
# Start and wait for the tasks to complete.
complete = loop.run_until_complete(asyncio.gather(*searches))
for term, search in zip(terms, complete):
print('Results for: {}'.format(term))
# Display the field '<FIELD>' of each result.
print('\n'.join([h['<FIELD>'] for h in search['hits']]))
```
With python >= 3.5.1
```python
import asyncio
from algoliasearchasync import ClientAsync
# Define a coroutine to be able to use `async with`.
async def main(terms):
# Scope the client for it to be closed automatically.
async with ClientAsync('<APP_ID>', '<API_KEY>') as client:
index = client.init_index('<INDEX_NAME>')
# Create as many searches as there is terms.
searches = [index.search_async(term) for term in terms]
# Return the aggregated results.
return await asyncio.gather(*searches)
terms = ['<TERM1>', '<TERM2>']
loop = asyncio.get_event_loop()
# Start and wait for the tasks to complete.
complete = loop.run_until_complete(main(terms))
for term, search in zip(terms, complete):
print('Results for {}'.format(term))
# Display the field '<FIELD>' of each result.
print('\n'.join([h['<FIELD>'] for h in search['hits']]))
```
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for algoliasearchasync-1.3.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b1877df7fc109f56ba7b035f380de37e077a68662f0df4ed696222aacd7daa88 |
|
MD5 | bd0c022e8ccbddeb3ada2822bf53b498 |
|
BLAKE2b-256 | 74a9b370535d9921125ee1019901dc0f87c273c7e26f9bf3f106ecb7f1c5befe |