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

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 ;

pip install mysql-connector-pythonpip install requests

# -*- coding: utf-8 -*-import requestsimport mysql.connectordef 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_listif __name__ == '__main__':  handle_data()