Django调用Nameko微服务使用简介

Django调用Nameko微服务使用简介

Nameko is a framework for building microservices in Python.
The example requires RabbitMQ, because it’s using the Nameko built-in AMQP RPC features.
Nameko微服务框架基于RabbitMQ的RPC远程调用协议。
Django REST framework is a powerful and flexible toolkit for building Web APIs.

一、前提

安装并运行RabbitMQ
在开发环境中使用 RabbitMQ 最简单的方式就是运行其官方的 docker 容器。（安装过程略）

docker run -d --hostname my-rabbit --name some-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:management

如果运行docker时没有指定用户名和密码，则使用默认值【guest】

docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password -p 15672:15672 -p 5672:5672 rabbitmq:management

网址：localhost:15672/

二、发布Nameko微服务

2.1、Install with Pip

pip install nameko

2.2、Service code

from nameko.rpc import rpc# A Nameko service is just a Python class
class ServiceRpc:# 微服务名称name = "service_rpc_hello"@rpcdef hello(self, name):return {"result": "Hello, {}!".format(name)}

2.3、Running a Service

2.3.1、使用命令参数指定RabbitMQ服务

nameko run --broker amqp://guest:guest@192.168.0.46 service_rpc

2.3.2、使用yaml配置文件指定RabbitMQ服务

nameko run --config rabbitmq.yaml service_rpc

rabbitmq.yaml 文件内容，如下：

AMQP_URI: 'pyamqp://guest:guest@192.168.0.46'

浏览器效果查看，如下：

2.4、调用服务演示

from nameko.standalone.rpc import ClusterRpcProxyconfig = {'AMQP_URI': 'pyamqp://guest:guest@192.168.0.46'
}if __name__ == '__main__':with ClusterRpcProxy(config) as cluster_rpc:# 同步调用res = cluster_rpc.service_rpc_hello.hello("firstname")print(res)# 异步调用res = cluster_rpc.service_rpc_hello.hello.call_async("asyname")sult())

三、Django调用Nameko微服务

创建Django官网示例mysite项目（略，参见：.0/intro/tutorial01/），示例代码使用DRF框架编写API接口。

3.1、pip install django_nameko

3.2、settings.py 增加nameko配置

# amqp地址
NAMEKO_CONFIG = {'AMQP_URI': 'amqp://guest:guest@192.168.101.46'
}
# 设置连接超时
NAMEKO_TIMEOUT = 10

3.3、api.py 后台接口

在polls文件夹中，新建api.py

from django_nameko import get_pool
from sponse import Response
from rest_framework.decorators import action
from rest_framework.viewsets import ModelViewSetclass NamekoViewSet(ModelViewSet):@action(detail=False, url_path='hello', methods=['GET'])def hello_msg(self, request, *args, **kwargs):name = quest.('name', 'world')try:with get_pool().next() as rpc:res = rpc.service_rpc_hello.hello(name)return Response({'result': 'hello {}!'.format(res)}, status=200)except Exception as e:print(e)return Response({'result': 'hello world!'}, status=200)@action(detail=False, url_path='hello_async', methods=['GET'])def hello_async(self, request, *args, **kwargs):name = quest.('name', 'world')try:with get_pool().next() as rpc:res = rpc.service_rpc_hello.hello.call_async(name)return sult(), status=200)except Exception as e:print(e)return Response({'result': 'hello world!'}, status=200)

3.4、urls.py

在polls的urls.py文件中，配置如下：

from .api import NamekoViewSetrouter = routers.DefaultRouter()
ister(r'', NamekoViewSet, basename='api')

3.5、浏览器查看效果

启动django项目

python manage.py runserver 0.0.0.0:8001

浏览器访问hello_async网址