Skip to main content

Reaction. ML serving & microservices.

Project description

Reaction logo

Convenient DL serving

Build Status Pipi version Docs PyPI Status Github contributors

Twitter Telegram Spectrum Slack

Part of Catalyst Ecosystem. Project manifest.


Common installation:

pip install -U reaction

Getting started

import asyncio
from typing import List, Any
from reaction.rpc import RabbitRPC

class rpc(RabbitRPC):
    URL = 'amqp://user:password@host'

def sync_square(*values) -> List[float]:
    return [v ** 2 for v in values]

async def async_square(*values) -> List[float]:
    await asyncio.sleep(1)
    return [v ** 2 for v in values]

if __name__ == '__main__':
    loop = asyncio.get_event_loop()

import asyncio
from consumer import sync_square, async_square

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    x = loop.run_until_complete(, 3))
    y = loop.run_until_complete(, 5, 6))
    print(x)  # 4, 9
    print(y)  # 16, 25, 36


  • Register telegram bot, achieve token
  • cd example && TG_TOKEN="telegram bot token goes here" docker-compose up --force-recreate --build
  • RabbitMQ web ui:
    • user: admin
    • password: j8XfG9ZDT5ZZrWTzw62q
  • Docs (you can submit requests from web ui):
  • Redoc:
  • Telegram bot is ready to classify ants & bees, but you have to send files "as a photo"

Telegram bot quick howto

Install async telegram client first:

$ pip install aiotg

Then create your bot:

from consumer import async_square
from aiotg import Bot, Chat

bot = Bot(api_token='telegram bot token goes here')

async def start(chat: Chat, match):
    return chat.reply('Send me /square command with one float argument')

@bot.command(r"/square (.+)")
async def square_command(chat: Chat, match):
    val =
        val = float(val)
        square = await
        resp = f'Square for {val} is {square}'
        resp = 'Invalid number'
    return chat.reply(resp)

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

reaction-20.2.tar.gz (6.6 kB view hashes)

Uploaded source

Built Distribution

reaction-20.2-py2.py3-none-any.whl (10.9 kB view hashes)

Uploaded py2 py3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page