微信运维交互机器人的示例代码

前言

今年五月份参加Oracle开发者大会,在会议上看到智能AI在运维方面的应用场景;讲师现场展现了一款能够结合上下文对话的智能AI,通过聊天方式完成运维工作。

会议后对该款智能AI机器人念念不忘,由于人工智能AI学习成本较高,寻思着是否能够写一套低配版运维交互机器人;

思考

初期期望该机器人能够:

  • 通过手机能够处理简单的故障
  • 不智能但至少配置能够灵活变更

有了具体的目标, 再考虑具体实现方案, 主要思考几个点:

应用载体

我期望这个载体是一款常用的手机APP;现有环境中微信企业号适合干这个事情, 且官网有各种API文档, 实施起来不是个什么巨大挑战.

安全性

涉及到运维平台,控制了运维平台就相当于控制了所有服务器;所以关系到运维平台的安全问题不可小窥,得确保在交互过程中的安全,在交互过程中需要加密,对不信任服务器进行策略管控.

灵活性

可以通过配置文件方式进行配置,后续随着功能模块增加可以随时进行更改,考虑到使用配置文件方式可能太过单一,花里胡哨的功能可能无法满足实现,尽量考虑又能花里胡哨,又能灵活管理配置的方案.

对话上下文

一般而言,通讯都需要一个长连接保证通信期间双方可以收发数据包; 考虑到一个对话就得专门起一个线程进行通信,这样不但增加开发难度,且更消耗资源, 权衡利弊后,对于上下文管理这一部分尽量选用非实时性方案去做.

架构

列出思考的几个关键点后,对整体的设计进行深入思考,几经思考后:

采用微信企业号作为应用载体

有关于企业号的开发传送门.

安全加固

接口平台只放通腾讯服务器IP访问.运维平台开放接口平台白名单访问,并且采用Python itsdangerous生成安全令牌进行通信交互.

程序设计思想

采用树结构设计模式,每个分叉为一个功能.这样就不必担心无法完成花里胡哨的操作,又能够灵活变更.

持久化存储接收信息

对每个用户发送的信息进行存储,并作出快速响应.Redis对于这个场景非常适用,既能够存储信息又十分高效.

架构图看起来大概是这样:

实现

接收企业号信息API代码片段展示

# 引用企业微信JDK
from WXcrypt.WXBizMsgCrypt import WXBizMsgCrypt

def work_weixin_api(request):
 # 获取微信Post参数
 msg_signature = request.GET.get('msg_signature', '')
 timestamp = request.GET.get('timestamp', '')
 nonce = request.GET.get('nonce', '')
 echostr = request.GET.get('echostr', '')

 # 构造微信信息解析方法
 wxcpt = WXBizMsgCrypt(WXTOKEN, WXENCODINGAESKEY, WXCROPID)
 if request.method == 'POST':
  eagle_branch = request.POST.get('eagle_branch', 'master')

  if eagle_branch == "master":
   request_data = request.body
   # 解析接收到的文本
   ret, msg = wxcpt.DecryptMsg(request_data, msg_signature, timestamp,
          nonce)
   request_xml = ET.fromstring(msg)

   # 获取信息内容
   content = request_xml.find("Content").text

   # 获取信息类型
   msg_type = request_xml.find("MsgType").text

   # 获取发送人
   from_user = request_xml.find("FromUserName").text
  else:
   content = request.POST.get('content', '')
   from_user = request.POST.get('from_user', '')

安全令牌生成

# 加密
def enc_dict(d):

 # 加密
 s = URLSafeSerializer('1234')
 st = s.dumps(d)

 # 加密后再生成基于时间戳的令牌
 t = TimestampSigner('4567')
 ts = t.sign(st)
 return ts

功能树设计代码片段展示

先定义一个功能树基类

# 菜单功能的基类
class Function:
 def __init__(self, data):
  self._data = data
  self._functions = []

 # 传入的方法的描述
 def __str__(self):
  return str(self._data())

 # 返回当前对象类型
 def f_type(self):
  return self._data.f_type

 # 返回当前对象
 def getData(self):
  return self._data

 # 返回所有子菜单
 def getFunctions(self):
  return self._functions

 # 新增子菜单
 def add(self, function):
  self._functions.append(function)

 # 递归搜索
 def go(self, num):
  for _, i in enumerate(self._functions):
   if int(num) == _ :
    return i
  return None

由于是在手机上操作, 那么交互内容尽可能简单,所以采用全数字交互方式.
在树结构设计模式下,所有操作都是在递归搜寻,对于其他特殊的输入,例如端口 确认验证码之类的无法实现.

在这里需要有小小的改动

 # 新增一个类型属性
 def f_type(self):
  return self._data.f_type

 # 递归搜索
 def go(self, num):
  for _, i in enumerate(self._functions):
   f_type = i._data().f_type
   # 如果类型是默认且存在列表中,或动态生成类型的,直接返回
   if f_type == "default" and int(num) == _ or f_type == "dynamic":
    return i
  return None

接着,编写一个功能树的类

class Menu:
 def __init__(self):
  self._head = Function(FunctionNodeBase())
  self.input_text = None

 # 链接
 def linkToHead(self, function):
  self._head.add(function)

 # 搜索
 def search(self, text):
  cur = self._head
  for i in text.split('-'):
   if cur.go(i) == None:
    return None
   else:
    self.input_text = i
    cur = cur.go(i)
  return cur

叶子的主体都有了,下面来创建树顶

展示: 基础功能叶 动态功能叶 静态功能叶

# 空的功能Node
class FunctionNodeBase:
 __metaclass__ = ABCMeta

 def __init__(self,
     user=None,
     f_type="default",
     input_text=None,
     sub_text=None):
  self.user = user
  self.sub_text = sub_text
  self.input_text = input_text
  self.f_type = f_type
  self.f_mark = []

 # 菜单通过run方法执行与生成文本
 @abstractmethod
 def run(self):
  return self.__str__()

 # 描述
 @abstractmethod
 def __str__(self):
  return "菜单树顶层"

# 动态生成
class SelectDeploymentTop(FunctionNodeBase):
 # 动态生成的菜单需要声明f_type
 def __init__(self):
  super().__init__()
  self.f_type = "dynamic"

 def run(self):

  text       = "请选择事业部\n\n"
  deployment_list = [i for i in FunctionList.keys()]

  for _, i in enumerate(deployment_list):
   self.f_mark.append(_)
   text += "%s %s\n" % (_, i)

  return text

 # 微信显示的文本信息
 def __str__(self):
  return "选择事业部"

# 静态
class MySQLFunctionTop(FunctionNodeBase):
 def __init__(self):
  super().__init__()

 def run(self):
  text = "您选择的是%s,请选择您想要操作:\n" % str(self.__str__())
  text += "%s\n" % self.sub_text
  return text

 def __str__(self):
  return "MySQL操作"

效果图,第一层功能展示

将需要的功能逐一写好后需要进行注册

def api(tid,user):

 # 实例化
 menu    = Menu()
 top     = Function(SelectDeploymentTop)
 function_top = Function(FunctionTop)
 mysql_top  = Function(MySQLFunctionTop)

 # 链接
 top.add(function_top
 function_top.add(mysql_top)

 # 关联菜单树
 menu.linkToHead(top)

 # 递归搜索
 function = menu.search(tid)

Redis存储对话代码片段

class redis_db:
 def __init__(self):
  # 按符号隔开
  self.mark = '-'
  self.redis_db = redis.StrictRedis(
   host = host, port=6379, db=1, decode_responses=True)

 # 默认回话过期600秒,每次存储 '-'隔开
 def add(self,key,text,Timeout=600):
  if key not in self.keys():
   self.redis_db.set(key,'',ex=Timeout)
  if self.get(key):
   self.redis_db.append(key,self.mark)
  self.redis_db.append(key,text)

同理,返回上层就删除一格; 退出即删除该KEY的值.

成果

下图为:通过交互机器人连接k8s增加POD数的应用场景

后记

该系统已经在平台上稳定运行大半年, 上线后使运维人员能够更高效快速解决日常中遇到的一些故障.

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • 快速实现基于Python的微信聊天机器人示例代码

    最近听说一个很好玩的图灵机器人api,正好可以用它做一个微信聊天机器人,下面是实现 # test.py import requests import itchat #这是一个用于微信回复的库 KEY = '8edce3ce905a4c1dbb965e6b35c3834d' #这个key可以直接拿来用 # 向api发送请求 def get_response(msg): apiUrl = 'http://www.tuling123.com/openapi/api' data = { 'key' :

  • C#图像识别 微信跳一跳机器人

    更新 GitHub中所有类库的源码已经转换为C#版本. 准备 IDE:VisualStudio Language:C#/VB.NET GitHub:AutoJump.NET 本文将向你介绍一种通过图像识别实现"跳一跳"机器人的方法. 第一节 图像识别 文中提到的所有方法和步骤只涉及简单的向量计算. 需要用到哪些计算? 比较像素点的颜色 求向量集合的中心 计算颜色的相似度 一个RGB颜色可以看作一个三维向量 比较两个颜色的相似度可以计算它们的欧几里得距离 也可以直接比较它们的夹角:夹角越

  • 使用图灵api创建微信聊天机器人

    需要准备的资源: 图灵机器人账号 微信公共账号 点击访问 图灵机器人官网,快快注册,拥有自己的聊天机器人,可以在这里先体验一下 今天主要简述微信公共平台聊天机器人的搭建,首先需要注册微信公共账号,之后在图灵机器人网站上登录你的图灵账号,可以看到如截图所示的界面,在"机器人设定"界面可以进行机器人昵称.年龄.性别等信息的设定,在"机器人调教"界面可以教你的机器人回答特定问题,"知识库"可以导入知识库,增加你的机器人的能力~~~ 红色圈起来的部分是需

  • 微信公众平台开发教程(四) 实例入门:机器人回复(附源码)

    上一篇文章,写了基本框架,可能很多人会觉得晕头转向,这里提供一个简单的例子来予以说明,希望能帮你解开谜团. 一.功能介绍 通过微信公众平台实现在线客服机器人功能.主要的功能包括:简单对话.查询天气等服务. 这里只是提供比较简单的功能,重在通过此实例来说明公众平台的具体研发过程.只是一个简单DEMO,如果需要的话可以在此基础上进行扩展. 当然后续我们还会推出比较复杂的应用实例. 二.具体实现 1.提供访问接口 这里不再赘述,参照上一章,微信公众账号开发教程(二) 基础框架搭建 http://www

  • 教你用Python创建微信聊天机器人

    最近研究微信API,发现个非常好用的python库:wxpy.wxpy基于itchat,使用了 Web 微信的通讯协议,实现了微信登录.收发消息.搜索好友.数据统计等功能. 这里我们就来介绍一下这个库,并在最后实现一个聊天机器人. 有没有很兴奋?有没有很期待? 好了,接下来,开始我们的正题. 准备工作 安装非常简单,从官方源下载安装 pip install -U wxpy 或者从豆瓣源安装 pip install -U wxpy -i "https://pypi.doubanio.com/sim

  • python使用itchat库实现微信机器人(好友聊天、群聊天)

    itchat是一个开源的微信个人号接口,可以使用该库进行微信网页版中的所有操作,比如:所有好友.添加好友.拉好友群聊.微信机器人等等.详细用户请看文档介绍,在这里. 本文主要使用该库完成一个能够处理微信消息的的图灵机器人,包括好友聊天.群聊天. 1.itchat库的安装 pip install itchat 安装完成后运行以下代码,会出现出现一张二维码,扫码登陆之后将会登陆微信网页. 2.登陆 import itchat # 登陆 itchat.auto_login() # 可设置hotRelo

  • 微信运维交互机器人的示例代码

    前言 今年五月份参加Oracle开发者大会,在会议上看到智能AI在运维方面的应用场景;讲师现场展现了一款能够结合上下文对话的智能AI,通过聊天方式完成运维工作. 会议后对该款智能AI机器人念念不忘,由于人工智能AI学习成本较高,寻思着是否能够写一套低配版运维交互机器人; 思考 初期期望该机器人能够: 通过手机能够处理简单的故障 不智能但至少配置能够灵活变更 有了具体的目标, 再考虑具体实现方案, 主要思考几个点: 应用载体 我期望这个载体是一款常用的手机APP;现有环境中微信企业号适合干这个事情

  • C#实现微信公众号会员卡管理的示例代码

    为了更好地理解微信公众号--会员卡管理,作者特意花了不少的时间对其研究,并用c#开发出会员卡demo,主要包含会员卡创建.设置开卡字段.通过创建二维码来投放会员卡.同步会员卡数据/激活会员卡.拉取会员信息.更新会员信息.设置会员卡失效.删除会员卡,从这些可以清晰地看出是围绕会员卡的生命周期来研究的.结合文章中DEMO有助于大家快速理解会员卡接口. 1.会员卡创建 1).会员卡创建接口文档   支持开发者调用该接口创建会员卡,并获取card_id,用于投放.调用该接口前,请开发者详读创建卡券接口部

  • python实现企业微信定时发送文本消息的示例代码

    企业微信定时发送文本消息 使用工具:企业微信机器人+python可执行文件+计算机管理中的任务计划程序 第一步:创建群机器人 选择群聊,单击鼠标右键,添加群机器人. 建立群机器人后,右键查看机器人,如下 复制机器人的链接. 第二步:编辑python程序 import requests from datetime import datetime url = 'https://qyapi.we......' #机器人的webhook地址 headers = {'Content-type':'appl

  • Python实现动态二维码生成的示例代码

    目录 第一个库:MyQR 普通的二维码制作 带背景图片的二维码制作 带动图背景的二维码制作 第二个库:qrcode 简单的二维码制作 带背景图片的二维码制作 大家好,我是辰哥~ 今天给大家分享两个制作二维码的Python库,可以生成普通的二维码.图片背景版二维码.动图GIF版二维. 第一个库:MyQR 安装 pip install MyQR 普通的二维码制作 from MyQR import myqr #运行 myqr.run('http://mtw.so/5w0Ubz') 二维码附上了链接,用

  • 13行python代码实现对微信进行推送消息的示例代码

    目录 单人推送 一对多推送 Python可以实现给QQ邮箱.企业微信.微信等等软件推送消息,今天咱们实现一下Python直接给微信推送消息. 这里咱们使用了一个第三方工具pushplus 单人推送 实现步骤: 1.用微信注册一个此网站的账号2.将token复制出来,记录到小本本上. 代码展示 import requests def send_wechat(msg): token = 'XXXXXXXXXXXX'#前边复制到那个token title = 'title1' content = ms

  • python使用自定义钉钉机器人的示例代码

    1.添加自定义机器人 2.编写python代码请求钉钉机器人所给的webhook 钉钉自定义机器人官方文档 安全方式使用加签的方式: 第一步,把timestamp+"\n"+密钥当做签名字符串,使用HmacSHA256算法计算签名,然后进行Base64 encode,最后再把签名参数再进行urlEncode,得到最终的签名(需要使用UTF-8字符集). 参数 说明 timestamp 当前时间戳,单位是毫秒,与请求调用时间误差不能超过1小时 secret 密钥,机器人安全设置页面,加签

  • Vue微信公众号网页分享的示例代码

    前言 今天做了个分享功能,反正挺诡异的,下面就来说一说步骤 后端使用egg.js,代码如下: 'use strict'; const Subscription = require('egg').Subscription; class AccessToken extends Subscription { static get schedule() { return { interval: '2h',//2小时获取一次 type: 'all', }; } async subscribe() { co

  • Python模拟简易版淘宝客服机器人的示例代码

    对于用Python制作一个简易版的淘宝客服机器人,大概思路是:首先从数据库中用sql语句获取相关数据信息并将其封装成函数,然后定义机器问答的主体函数,对于问题的识别可以利用正则表达式来进行分析,结合现实情况选择答案,最后在执行时可以设置循环语句,并且在每次回答间隔1s方便进一步做并发处理作为未来优化方向.从以下几个方面分别实现: 1.货物信息储存到MySQL数据库中 在现实情景中,购物信息的数据一般会储存到数据库中,方便在进行问答时才访问数据库获取相关信息,可以用Python中的sqlalche

  • 使用SSM+Layui+Bootstrap实现汽车维保系统的示例代码

    本项目主要实现对汽车维修厂的信息化管理功能,主要包含三个角色:管理员,维修师傅,客户.实现的主要功能包含用户管理.配置管理.汽车管理.故障管理.供应商管理.配件管理.维修订单管理.统计信息.公告管理.个人信息管理.主要业务流程:用户在系统内发起汽车维修申请定单,管理员根据情况将定单分配给维修师傅,维修师傅接受任务后开始维修,并根据情况申请配件,处理完成后由管理员生成最终支付订单结算费用,客户进入系统进行费用支付,并可以查看自己相应的维修记录和费用信息等等. 技术架构: 后台开发:SSM框架 前端

  • uniapp 实现微信小程序全局分享的示例代码

    目录 创建全局分享内容文件 引入并全局注册该文件 自定义页面分享内容  uniapp 实现微信小程序的全局转发给好友/分享到朋友圈的功能.主要使用 Vue.js 的 全局混入 概念. 下面直接上 实现步骤和代码: 创建全局分享内容文件 1.创建一个全局分享的 js 文件.示例文件路径为:@/common/share.js ,在该文件中定义全局分享的内容: export default { data() { return { // 默认的全局分享内容 share: { title: '全局分享的标

随机推荐