使用 Python 实现微信公众号粉丝迁移流程_Python

使用 Python 实现微信公众号粉丝迁移流程

2020-12-30 01:07adanz Python

近日，因公司业务需要，需将原两个公众号合并为一个，即要将其中一个公众号（主要是粉丝）迁移到另一个公众号。这篇文章主要介绍了使用 Python 实现微信公众号粉丝迁移,需要的朋友可以参考下

近日，因公司业务需要，需将原两个公众号合并为一个，即要将其中一个公众号（主要是粉丝）迁移到另一个公众号。按微信规范，同一用户在不同公众号内的 openid 是不同的，我们的业务系统不例外地记录了用户的 openid,因此，涉及到两个公众号的 openid 的转换。幸好，微信公众号平台在账号迁移描述提供了方法和API供调用，详见：

http://kf.qq.com/faq/170221aUnmmU170221eUZJNf.html

这里使用 Python 写个程序来完成，简单快捷，主要知识点有：

MySQL connector 使用，也就是 Python DB API 规范
HTTP客户端库 requests 使用
微信公众号平台 API 使用

首先，建立新旧 openid 对照表。

									CREATE TABLE change_openidlist(

									  id BIGINT NOT NULL AUTO_INCREMENT,

									  ori_openid varchar(100) NOT NULL,

									  new_openid varchar(100) NOT NULL,

									  CONSTRAINT crm_change_openidlist_pk PRIMARY KEY (id)

									) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci ;

如果没有安装，则需先安装以下类库。

1 2	`pip install mysql-connector-python` `pip install requests`

接着，运行下面 python 程序，即可将新旧 openid 对照数据写到 change_openidlist，然后就可以根据这个表的数据去更新其它数据表了。

其它可见注释，不详述，当然不要忘了将 appid 和 secret 替换为自己公众号。

									# -*- coding: utf-8 -*-

									import requests

									import mysql.connector

									def handle_data():

									  try:

									    token = get_access_token()

									    #自动提交方式 autocommit=True

									    conn = mysql.connector.connect(host='127.0.0.1', port='3306', user='user', password='password', database='wx', use_unicode=True,autocommit=True);

									    qcursor = conn.cursor(buffered=True)

									    wcursor = conn.cursor()

									    #旧公众号 openid

									    qcursor.execute('select openid from wxmembers')

									    size = 100

									    while True:

									      list = qcursor.fetchmany(size)

									      if not list:

									        break

									      changeopenid_list = get_changeopenid_list(list,token)

									      wcursor.executemany('insert into change_openidlist (ori_openid,new_openid) values (%s, %s)',changeopenid_list)

									  except mysql.connector.Error as e:

									    print ('Error : {}'.format(e))

									  finally:

									    qcursor.close

									    wcursor.close()

									    conn.close

									    print 'openid handle finished!'

									def get_access_token():

									  new_appid = '00000'

									  new_secret = '11111'

									  url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential' # grant_type为固定值

									  payload = {'appid': new_appid, 'secret': new_secret}

									  r = requests.get(url,params = payload)

									  response = r.json()

									  return response['access_token']

									def get_changeopenid_list(ori_openid_list,token):

									  new_access_token = token

									  ori_appid = '33333'

									  url = 'http://api.weixin.qq.com/cgi-bin/changeopenid?access_token='+ new_access_token

									  payload = {'to_appid': ori_appid, 'openid_list': ori_openid_list}

									  r = requests.post(url,json = payload)

									  response = r.json()

									  result_list = response['result_list']

									  openid_list = [[result['ori_openid'],result['new_openid']] for result in result_list if result['err_msg'] == 'ok']

									  return openid_list

									if __name__ == '__main__':

									  handle_data()