1. 数据导入到redis中
import pypyodbc import time import redis start = time.ctime() client = pypyodbc.connect(driver='{SQL Server}',server='服务器', database='数据库', uid='用户', pwd='密码', autocommit=True) r = redis.Redis(host='redis 服务器', password='密码') cursor = client.cursor() cursor.execute('select company_name from SzCompany') result = True while result: result = cursor.fetchone() if result: r.lpush('company_name:zl', result[0])
cursor.close()
client.close()