python_mqtt_zdh/jf_air_north.py

from sys import path
path.append("D:\proj\python\zdh")
import mqtt_client as mc
import config_info_model as md
import redis
import json


if __name__ == "__main__":
    sys_key = 'jinfeng'
    sys_name = 'air_north'
    cf = md.configInfoModel(sys_key, sys_name)
    # 读取例子数据
    tpdata = cf.get_temp(sys_key, sys_name)
    values_list = tpdata['values']
    # print(type(tpdata['values']))
    # 转换成k->v
    point_dict = {}
    for i in range(len(values_list)):
        d = values_list[i]
        point_dict[d['code']] = d['v']
    
    # 读取最终json格式数据
    jdata = cf.get_json(sys_key, sys_name)
    jdata_s = jdata['sys_point']
    
    # 赋值
    for key, val in jdata_s.items():
        for i in range(len(val)):
            ck = val[i]['key']
            if ck in point_dict.keys():
                val[i]['val'] = point_dict[ck]
        jdata_s[key] = val
    jdata['sys_point'] = jdata_s
    
    # 存入redis
    config = cf.get_conf()
    
    try:
        redis_conf = config['redis_conf']
        redis_ip = redis_conf['ip']
        pool = redis.ConnectionPool(host=redis_ip, password='')
        redis_conn = redis.Redis(connection_pool=pool)
        # 接口数据存入redis
        redis_key = f"{sys_key}_{sys_name}"
        json_str = json.dumps(jdata)
        redis_conn.set(str(redis_key), json_str)
    except BaseException as e:
        print(e)
        print("异常，redis连接错误！")
    # return redis_conn