1. 数据分析网首页
  2. 软件工具
  3. Python

Python快速搭建自动回复微信公众号

在之前的一篇文章 Python利用 AIMLTornado 搭建聊天机器人微信订阅号 中用 aiml 实现了一个简单的英文聊天机器人订阅号。但是只能处理英文消息,现在用 图灵机器人 来实现一个中文的聊天机器人订阅号。

这里主要介绍如何利用 PythonTornado Web框架以及wechat-python-sdk 微信公众平台 Python 开发包来快速搭建微信公众号。

完整的公众号代码 GitHub 地址:green ,由于目前此公众号有一些功能正在开发中,此完整代码会与下文所描述的代码有不一致的地方,但是自动回复的功能会一直保留。

本文搭建的微信公众号为 Ms_haoqi,可以扫码关注后测试效果

二维码

自动回复效果:
Python快速搭建自动回复微信公众号

安装Python库

通过 pip 安装 wechat-python-sdkRequests 以及 Tornado

1

2

3

pip install tornado

pip install wechat-sdk

pip install requests

订阅号申请

要搭建订阅号,首先需要在微信公众平台官网进行注册,注册网址: 微信公众平台。

目前个人用户可以免费申请微信订阅号,虽然很多权限申请不到,但是基本的消息回复是没有问题的。

服务器接入

具体的接入步骤可以参考官网上的接入指南

本订阅号的配置为:
Python快速搭建自动回复微信公众号

配置里的URL为服务器提供订阅号后台的url路径,本文用到的源代码配置的是 http://server_ip/wx 其中server_ip 是运行源代码的主机的公网ip地址。

Token 可以设置为任意字符串。

EncodingAESKey 可以选择随机生成。

消息加密方式可以设置为比较简单的明文模式。

接受并处理微信服务器发送的接入请求的关键代码为Tornado的一个Handle, wx.py :

<div “>

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

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

24

25

26

27

28

<div

<div’static_path’: os.path.join(os.path.dirname(__file__), ‘static’),

<div’template_path’: os.path.join(os.path.dirname(__file__), ‘view’),

<div’cookie_secret’: ‘e440769943b4e8442f09de341f3fea28462d2341f483a0ed9a3d5d3859f==78d’,

<div’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

27

28

<div# -*- coding: utf-8 -*-

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部分代码:

Python

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

33

34

35

# -*- 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

来源:http://blog.csdn.net/tobacco5648/article/details/51190039

本文采用「CC BY-SA 4.0 CN」协议转载自互联网、仅供学习交流,内容版权归原作者所有,如涉作品、版权和其他问题请给「我们」留言处理。

联系我们

如有建议:>>给我留言

QR code