radical-rpc 0.1.7

关于

Radical是一个RPC库，它允许您实现跨服务通信。

它可以作为Celery的替代品。

Radical与Django有开箱即用的集成，也支持asyncio，但也可以不使用它。

Radical可以很容易地通过自定义传输和序列化器进行扩展。

可用传输

• Redis

• Postgres

默认和推荐传输是Redis。

可用序列化器

• JSON

• Pickle

默认和推荐序列化器是Pickle。

术语表

安装

pip install radical-rpc

与Django一起使用

1. 将Radical添加到INSTALLED_APPS

   INSTALLED_APPS = [
       # ...
       'radical',
       # ...
   ]

2. 配置Radical

   RADICAL_CONFIG = {
       'TRANSPORT_URL': 'redis://redis:6379/0?request_timeout=10',
       'QUEUE_NAME': 'myapp',
       'MODULES': [
           'radical.demo'
       ]
   }

3. 在任何地方调用它

   from radical.contrib.django import call_wait, call
   from django.http import JsonResponse
   
   def some_view(request):
       # Call remote method and wait for it to return result.
       result = call_wait('myapp', 'radical.demo.add', 1300, 37)
       return JsonResponse(dict(result=result))  # Returns {'result': 1337}
   
   def some_view(request):
       # Call remote method and do not wait for it to finish.
       call('myapp', 'radical.demo.add', 1300, 37)
       return JsonResponse(dict(result='Job was scheduled.'))

4. 启动Radical工作进程

   ./manage.py radical