Python+redis获取动态参数

1、使用flask编写接口

@server.route()可以将普通函数转变为服务登录接口的路径、请求方式

如：@server.route('/in_data', methods=['get'])就是创建一个route名叫in_data的接口，请求方式为get，以下即完成了Python编写接口

#!/usr/bin/python3
# -*- coding: utf-8 -*-
import redis
import flask
import json
from flask import request
from wsgiref.simple_server import make_server

'''
flask： web框架，通过flask提供的装饰器@server.route()将普通函数转换为服务
'''
# 创建一个服务，把当前这个python文件当做一个服务
server = flask.Flask(__name__)
@server.route('/in_data', methods=['get'])
def in_data():
  # 获取通过url请求传参的数据
  shop = request.values.get('shop')
  # 获取url请求传的密码，明文
  orders = request.values.get('orders')
  # mails = request.values.get('mails')
  keywords = request.values.get('keywords')
  sell = request.values.get('sell')
  new = request.values.get('new')
  amount = request.values.get('amount')
  account = request.values.get('account')
  password = request.values.get('password')
  domain_name = request.values.get('domain_name')
  # 判断用户名、密码都不为空
  if shop and orders and keywords and sell and new and amount and account and password and domain_name:
      resu = {'code': 0, 'result': True, 'msg': '操作成功'}
      connect_redis(shop, orders, keywords, sell, new, amount, account, password, domain_name)
      return json.dumps(resu, ensure_ascii=False)  # 将字典转换字符串
  else:
      resu = {'code': 4001, 'result': False, 'msg': '参数错误'}
      return json.dumps(resu, ensure_ascii=False)
  
if __name__ == '__main__':
    server.run(debug=True, port=8080, host='192.x.x.x')

Linux中安装和搭建redis（安装教程），前面接口用来获取参数，下面代码用来存入redis，Python调用redis和存取参数的代码如下：

def connect_redis(*args):
    r = redis.Redis(host='localhost', port=6379, decode_responses=True)
    shop = args[0]
    orders = args[1]
    keywords = args[2]
    sell = args[3]
    new = args[4]
    amount = args[5]
    account = args[6]
    password = args[7]
    domain_name = args[8]
    r.set("shop", shop)  # 店铺数
    r.set("orders", orders)  # 单量套餐剩余额度
    r.set("keywords", keywords)  # 关键词剩余
    r.set("sell", sell)  # 跟卖ASIN
    r.set("new", new)  # 上新店铺
    r.set("amount", amount)  # 充值金额
    r.set("account", account)  # 账号
    r.set("password", password)  # 密码
    r.set("domain_name", domain_name)  # 域名