在之前的一篇文章 Python利用 AIML 和 Tornado 搭建聊天机器人微信订阅号 中用 aiml 实现了一个简单的英文聊天机器人订阅号。但是只能处理英文消息,现在用 图灵机器人 来实现一个中文的聊天机器人订阅号。
这里主要介绍如何利用 Python 的 Tornado Web框架以及wechat-python-sdk 微信公众平台 Python 开发包来快速搭建微信公众号。
完整的公众号代码 GitHub 地址:green ,由于目前此公众号有一些功能正在开发中,此完整代码会与下文所描述的代码有不一致的地方,但是自动回复的功能会一直保留。
本文搭建的微信公众号为 Ms_haoqi,可以扫码关注后测试效果
自动回复效果:
安装Python库
通过 pip 安装 wechat-python-sdk , Requests 以及 Tornado
1
2
3
|
pip install tornado pip install wechat - sdk pip install requests |
订阅号申请
要搭建订阅号,首先需要在微信公众平台官网进行注册,注册网址: 微信公众平台。
目前个人用户可以免费申请微信订阅号,虽然很多权限申请不到,但是基本的消息回复是没有问题的。
服务器接入
具体的接入步骤可以参考官网上的接入指南。
本订阅号的配置为:
配置里的URL为服务器提供订阅号后台的url路径,本文用到的源代码配置的是 http://server_ip/wx 其中 server_ip 是运行源代码的主机的公网ip地址。
Token 可以设置为任意字符串。
EncodingAESKey 可以选择随机生成。
消息加密方式可以设置为比较简单的明文模式。
接受并处理微信服务器发送的接入请求的关键代码为Tornado的一个Handle, wx.py :
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
import tornado.escape import tornado.web from wechat_sdk import WechatConf conf = WechatConf( token = 'your_token' , # 你的公众号Token appid = 'your_appid' , # 你的公众号的AppID appsecret = 'your_appsecret' , # 你的公众号的AppSecret encrypt_mode = 'safe' , # 可选项:normal/compatible/safe,分别对应于 明文/兼容/安全 模式 encoding_aes_key = 'your_encoding_aes_key' # 如果传入此值则必须保证同时传入 token, appid ) from wechat_sdk import WechatBasic wechat = WechatBasic(conf = conf) class WX(tornado.web.RequestHandler): def get( self ): signature = self .get_argument( 'signature' , 'default' ) timestamp = self .get_argument( 'timestamp' , 'default' ) nonce = self .get_argument( 'nonce' , 'default' ) echostr = self .get_argument( 'echostr' , 'default' ) if signature ! = 'default' and timestamp ! = 'default' and nonce ! = 'default' and echostr ! = 'default' \ and wechat.check_signature(signature, timestamp, nonce): self .write(echostr) else : self .write( 'Not Open' ) |
此代码的作用就是验证消息是来自微信官方服务器后直接返回echostr。
启动后台的 main.py 代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
import tornado.web import tornado.httpserver from tornado.options import define, options settings = { 'static_path' : os.path.join(os.path.dirname(__file__), 'static' ), 'template_path' : os.path.join(os.path.dirname(__file__), 'view' ), 'cookie_secret' : 'e440769943b4e8442f09de341f3fea28462d2341f483a0ed9a3d5d3859f==78d' , 'login_url' : '/' , 'session_secret' : "3cdcb1f07693b6e75ab50b466a40b9977db123440c28307f428b25e2231f1bcc" , 'session_timeout' : 3600 , 'port' : 5601 , 'wx_token' : 'weixin' , } web_handlers = [ (r '/wx' , wx.WX), ] define( "port" , default = settings[ 'port' ], help = "run on the given port" , type = int ) if __name__ = = '__main__' : app = tornado.web.Application(web_handlers, * * settings) tornado.options.parse_command_line() http_server = tornado.httpserver.HTTPServer(app) http_server.listen(options.port) tornado.ioloop.IOLoop.instance().start() |
配置好程序源代码后运行,确认运行无误后再在公众号设置页面点击 提交 ,如果程序运行没问题,会显示接入成功。
接入图灵机器人
要接入图灵机器人,首先需要在官网申请API Key。
申请到之后可以利用以下代码包装一个自动回复接口:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
# -*- coding: utf-8 -*- import json import requests import traceback class TulingAutoReply: def __init__( self , tuling_key, tuling_url): self .key = tuling_key self .url = tuling_url def reply( self , unicode_str): body = { 'key' : self .key, 'info' : unicode_str.encode( 'utf-8' )} r = requests.post( self .url, data = body) r.encoding = 'utf-8' resp = r.text if resp is None or len (resp) = = 0 : return None try : js = json.loads(resp) if js[ 'code' ] = = 100000 : return js[ 'text' ].replace( '<br>' , '\n' ) elif js[ 'code' ] = = 200000 : return js[ 'url' ] else : return None except Exception: traceback.print_exc() return None |
编写公众号自动回复代码
利用 wechat-python-sdk 微信公众平台 Python 开发包可以很容易地处理公众号的所有消息。
如下为处理来自微信官方服务器的微信公众号消息的 Tornado Handler对象(此代码会获取公众号收到的用户消息并调用刚刚包装的图灵机器人API自动回复) wx.py部分代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
# -*- coding: utf-8 -*- import tornado.escape import tornado.web auto_reply = TulingAutoReply(key, url) # key和url填入自己申请到的图灵key以及图灵请求url class WX(tornado.web.RequestHandler): def wx_proc_msg( self , body): try : wechat.parse_data(body) except ParseError: print 'Invalid Body Text' return if isinstance (wechat.message, TextMessage): # 消息为文本消息 content = wechat.message.content reply = auto_reply.reply(content) if reply is not None : return wechat.response_text(content = reply) else : return wechat.response_text(content = u "不知道你说的什么" ) return wechat.response_text(content = u '知道了' ) def post( self ): signature = self .get_argument( 'signature' , 'default' ) timestamp = self .get_argument( 'timestamp' , 'default' ) nonce = self .get_argument( 'nonce' , 'default' ) if signature ! = 'default' and timestamp ! = 'default' and nonce ! = 'default' \ and wechat.check_signature(signature, timestamp, nonce): body = self .request.body.decode( 'utf-8' ) try : result = self .wx_proc_msg(body) if result is not None : self .write(result) except IOError, e: return |
关于Python开发之快速搭建自动回复微信公众号功能就给大家介绍这么多,希望对大家有所帮助!