معرفی شرکت ها
deepomatic-rpc-0.8.9
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
Deepomatic RPC python client
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | deepomatic-rpc-0.8.9 |
| نام | deepomatic-rpc |
| نسخه کتابخانه | 0.8.9 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | deepomatic |
| ایمیل نویسنده | support@deepomatic.com |
| آدرس صفحه اصلی | https://www.deepomatic.com |
| آدرس اینترنتی | https://pypi.org/project/deepomatic-rpc/ |
| مجوز | UNLICENSED |
# Table of contents
- [Deepomatic Remote Procedure Call](#deepomatic-remote-procedure-call)
- [Installation](#installation)
- [Usage](#usage)
* [Getting started](#getting-started)
+ [Instanciate client and queues](#instanciate-client-and-queues)
+ [Send recognition request](#send-recognition-request)
+ [Stream and cleanup](#stream-and-cleanup)
* [Advanced](#advanced)
+ [Shortcuts](#shortcuts)
+ [Image input examples](#image-input-examples)
- [Bugs](#bugs)
# Deepomatic Remote Procedure Call
[Deepomatic](https://www.deepomatic.com) Remote Procedure Call.
This remote procedure call has been made to help you interacting with our on-premises inference service.
You might also want to use our command line interface [deepomatic-cli](https://pypi.org/project/deepomatic-cli/).
# Installation
# Online
```bash
pip3 install deepomatic-rpc
```
# Offline
On a machine with internet access you will need to download the package and its dependencies with the command below:
```bash
mkdir deepomatic-rpc
# --platform force to get the packages compatibles with all OS
pip3 download --platform any --only-binary=:all: -d ./deepomatic-rpc deepomatic-rpc
```
Then save the `deepomatic-rpc` directory on the storage device of your choice.
Now retrieve this directory on the offline machine and install the package:
```bash
pip3 install --no-index --find-links ./deepomatic-rpc ./deepomatic-rpc/deepomatic_rpc-*-py3-none-any.whl
```
# Usage
## Getting started
### Instanciate client and queues
```python
from deepomatic.rpc.client import Client
# Replace placeholder variables with yours
command_queue_name = 'my_command_queue'
recognition_version_id = 123
amqp_url = 'amqp://myuser:mypassword@localhost:5672/myvhost'
# Instanciate client
client = Client(amqp_url)
# Do the following for each stream
# Declare lasting command queue
command_queue = client.new_queue(command_queue_name)
# Declare response queue and consumer to get responses
# consumer is linked to the response_queue
# If queue_name parameter is provided, will declare a durable queue
# Otherwise it is an uniq temporary queue.
response_queue, consumer = client.new_consuming_queue()
# Don't forget to cleanup when you are done sending requests !
```
### Send recognition request
```python
from deepomatic.rpc import v07_ImageInput
from deepomatic.rpc.response import wait
from deepomatic.rpc.helpers.v07_proto import create_images_input_mix, create_recognition_command_mix
# Create a recognition command mix
command_mix = create_recognition_command_mix(recognition_version_id, max_predictions=100, show_discarded=False)
# Create one image input
image_input = v07_ImageInput(source='https://static.wamiz.fr/images/animaux/chats/large/bengal.jpg'.encode())
# Wrap it inside a generic input mix
input_mix = create_images_input_mix([image_input])
# Send the request
correlation_id = client.command(command_queue_name, response_queue.name, command_mix, input_mix)
# Wait for response, `timeout=float('inf')` or `timeout=-1` for infinite wait, `timeout=None` for non blocking
response = consumer.get(correlation_id, timeout=5)
# get_labelled_output() is a shortcut that give you the corresponding predictions depending on the command mix you used
# and raise a ServerError in case of error on the worker side. It should cover most cases but if it doesn't fit your needs, see the Response class. You might want to handle result and errors by yourself using `response.to_result_buffer()`.
labels = response.get_labelled_output()
predicted = labels.predicted[0] # Predicted is ordered by score
print("Predicted label {} with score {}".format(predicted.label_name, predicted.score))
# if show_discarded was True, you might want to read `labels.discarded` to see which labels have a low confidence.
```
### Stream and cleanup
When you are done with a stream you should cleanup your consuming queues.
- If your program stops right after, the consumer get cancelled and the queue will automatically be removed after 2 hours of inactivity (only if the queue is a uniq temporary queue).
- If your program is a long running job, after 2 hours of inactivity the queue might be removed and the consumer cancelled by the broker, but the client might consider redeclaring both in case of a broker error.
Thus calling `client.remove_consuming_queue()` remove the queue and makes sure the consumer is cancelled and not redeclared later:
```python
client.remove_consuming_queue(response_queue, consumer)
```
You might also want to remove a queue without consumer using:
```python
client.remove_queue(queue)
```
Also instead of using `new_consuming_queue()` with no queue_name parameter and `remove_consuming_queue()` you might want to use the contextmanager version:
```python
with client.tmp_consuming_queue() as (response_queue, consumer):
# this creates a temporary queue alive for the rest of this scope
# do your inference requests
```
If you don't want to care about the response queue and consumer, we provide a high level class `RPCStream`.
By default it saves all correlation_ids so that you can call `get_next_response()` to get responses in the same order that you pushed the requests:
```python
from deepomatic.rpc.helpers.proto import create_v07_images_command
serialized_buffer = create_v07_images_command([image_input], command_mix)
with client.new_stream(command_queue_name) as stream:
# it internally saves the correlation_id so that it can retrieve responses in order
# You need to call as many time get_next_response() as send_binary(), or the internal correlation_ids list will keep growing up
stream.send_binary(serialized_buffer)
response = stream.get_next_response(timeout=1)
```
Also you might want to handle response order by yourself, in this case you can create the stream in the following way:
```python
# with keep_response_order=False, the stream will not buffer correlation_ids
with client.new_stream(command_queue_name, keep_response_order=False):
correlation_id = stream.send_binary(serialized_buffer)
# directly access the stream's consumer to retrieve a specific response
response = stream.consumer.get(correlation_id, timeout=1)
```
**IMPORTANT**: If you don't use the with statement, you will have to call `stream.close()` at the end to clean consumer and response queue.
## Advanced
### Shortcuts
* You can avoid calling `create_images_input_mix` and directly sending the image_input list via the method `client.v07_images_command` which will call internally `create_images_input_mix`:
```python
correlation_id = client.v07_images_command(command_queue_name, response_queue.name, [image_input], command_mix)
```
* Create a workflow command mix. The recognition_version_id is deduced but the command queue name must match the recognition in the workflows.json.
Note that it doesn't allow to specify `show_discarded` or `max_predictions`:
```python
from deepomatic.rpc.helpers.v07_proto import create_workflow_command_mix
command_mix = create_workflow_command_mix()
```
* Create an inference command mix; the response will be a raw tensor :
```python
from deepomatic.rpc.helpers.v07_proto import create_inference_command_mix
output_tensors = ['prod']
command_mix = create_inference_command_mix(output_tensors)
```
* Wait multiples correlation ids at once:
```python
from deepomatic.rpc.response import wait_responses
# Wait for responses, `timeout=float('inf')` or `timeout=-1` for infinite wait
responses, pending = wait_responses(consumer, correlation_ids, timeout=10)
print(responses)
# will print [(0, response), (1, response), (2, response)]
# 0, 1, 2 are the position in correlation_ids list in case you want to retrieve their original correlation_id
# the list is sorted by positions to keep the same order as the correlation_ids list
# if no timeout reached len(response) == len(correlation_ids)
print(pending)
# should be empty if timeout has not been reached
# otherwise should print a list of correlation_id position that didn't get a response (the list is sorted)
# If print [3, 5], then correlations_ids[3] and correlation_id[5] didn't get a response on time
```
### Image input examples
* Create an image input with a bounding box:
```python
from deepomatic.rpc import v07_ImageInput
from deepomatic.rpc import BBox
# Coordinates between 0 and 1
bbox = BBox(xmin=0.3, xmax=0.8, ymin=0.1, ymax=0.9)
image_input = v07_ImageInput(source='https://static.wamiz.fr/images/animaux/chats/large/bengal.jpg'.encode(),
bbox=bbox)
```
* Create an image input with a polygon selection:
```python
from deepomatic.rpc import v07_ImageInput
from deepomatic.rpc import Point
# Coordinates between 0 and 1, minimum 3 points needed
polygon = [Point(x=0.1, y=0.1), Point(x=0.9, y=0.1), Point(x=0.5, y=0.9)]
image_input = v07_ImageInput(source='https://static.wamiz.fr/images/animaux/chats/large/bengal.jpg'.encode(),
polygon=polygon)
```
* Create an image input from a file on the disk:
```python
from deepomatic.rpc import v07_ImageInput
from deepomatic.rpc.helpers.proto import binary_source_from_img_file
binary_content = binary_source_from_img_file(filename) # Also works if you give a fileobj
image_input = v07_ImageInput(source=binary_content)
```
# Bugs
Please send bug reports to support@deepomatic.com
نیازمندی
| مقدار | نام |
|---|---|
| <5.0.0,>=4.6.0 | kombu |
| <=3.19.5,>=3.9.2 | protobuf |
| <=1.51.1,>=1.20.1 | grpcio |
نحوه نصب
نصب پکیج whl deepomatic-rpc-0.8.9:
pip install deepomatic-rpc-0.8.9.whl
نصب پکیج tar.gz deepomatic-rpc-0.8.9:
pip install deepomatic-rpc-0.8.9.tar.gz