Commit f25be0a7 authored by 张晓彤's avatar 张晓彤

settings路径

parent c8697ba0
#!E:\Pycharm Projects\Waytous #!E:\Pycharm Projects\Waytous
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
# @Time : 2021/7/23 11:25 # @Time : 2021/7/23 11:25
# @Author : Opfer # @Author : Opfer
# @Site : # @Site :
# @File : settings.py # @File : settings.py
# @Software: PyCharm # @Software: PyCharm
# 数据库设备, redis设置, 日志设置 # 数据库设备, redis设置, 日志设置
from tables import * from tables import *
from urllib.parse import quote from urllib.parse import quote
import logging.handlers import logging.handlers
import numpy as np import numpy as np
import os import os
from redis import StrictRedis, ConnectionPool from redis import StrictRedis, ConnectionPool
import redis import redis
from datetime import datetime, timedelta from datetime import datetime, timedelta
import copy import copy
import json import json
import sched import sched
import time import time
# 创建日志 # 创建日志
######################################################################################################################## ########################################################################################################################
# 日志存储地址 # 日志存储地址
log_path = "/usr/local/fleet-log/dispatch" log_path = "/usr/local/fleet-log/dispatch"
# 创建日志目录 # 创建日志目录
# if not os.path.exists(log_path): if not os.path.exists(log_path):
# os.mkdir(log_path) os.mkdir(log_path)
# logging初始化工作 # logging初始化工作
logging.basicConfig() logging.basicConfig()
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO) logger.setLevel(logging.INFO)
# timefilehandler = logging.handlers.TimedRotatingFileHandler(log_path + "/dispatch.log", when='M', interval=1, backupCount=60) # timefilehandler = logging.handlers.TimedRotatingFileHandler(log_path + "/dispatch.log", when='M', interval=1, backupCount=60)
# filehandler = logging.handlers.RotatingFileHandler(log_path + "/dispatch.log", maxBytes=3*1024*1024, backupCount=10) filehandler = logging.handlers.RotatingFileHandler(log_path + "/dispatch.log", maxBytes=3*1024*1024, backupCount=10)
filehandler = logging.handlers.RotatingFileHandler("./Logs/dispatch.log", maxBytes=3 * 1024 * 1024, backupCount=10) # filehandler = logging.handlers.RotatingFileHandler("./Logs/dispatch.log", maxBytes=3 * 1024 * 1024, backupCount=10)
# 设置后缀名称,跟strftime的格式一样 # 设置后缀名称,跟strftime的格式一样
filehandler.suffix = "%Y-%m-%d_%H-%M.log" filehandler.suffix = "%Y-%m-%d_%H-%M.log"
formatter = logging.Formatter("%(asctime)s - %(name)s: %(levelname)s %(filename)s %(message)s") formatter = logging.Formatter("%(asctime)s - %(name)s: %(levelname)s %(filename)s %(message)s")
filehandler.setFormatter(formatter) filehandler.setFormatter(formatter)
logger.addHandler(filehandler) logger.addHandler(filehandler)
# 连接reids # 连接reids
######################################################################################################################## ########################################################################################################################
# redis 5 存储设备状态 # redis 5 存储设备状态
pool5 = ConnectionPool(host="192.168.28.111", db=5, port=6379, password="Huituo@123") pool5 = ConnectionPool(host="192.168.28.111", db=5, port=6379, password="Huituo@123")
redis5 = StrictRedis(connection_pool=pool5) redis5 = StrictRedis(connection_pool=pool5)
# redis 2 存储派车计划 # redis 2 存储派车计划
pool2 = ConnectionPool(host="192.168.28.111", db=2, port=6379, password="Huituo@123") pool2 = ConnectionPool(host="192.168.28.111", db=2, port=6379, password="Huituo@123")
redis2 = StrictRedis(connection_pool=pool2) redis2 = StrictRedis(connection_pool=pool2)
# 数据库连接设置 # 数据库连接设置
######################################################################################################################## ########################################################################################################################
# 创建对象的基类: # 创建对象的基类:
Base = declarative_base() Base = declarative_base()
try: try:
engine_mysql = create_engine( engine_mysql = create_engine(
"mysql+mysqlconnector://root:%s@192.168.28.111:3306/waytous" "mysql+mysqlconnector://root:%s@192.168.28.111:3306/waytous"
% quote("Huituo@123") % quote("Huituo@123")
) )
engine_postgre = create_engine( engine_postgre = create_engine(
"postgresql://postgres:%s@192.168.28.111:5432/shenbao_2021520" "postgresql://postgres:%s@192.168.28.111:5432/shenbao_2021520"
% quote("Huituo@123") % quote("Huituo@123")
) )
# 创建DBsession_mysql类型: # 创建DBsession_mysql类型:
DBsession_mysql = sessionmaker(bind=engine_mysql) DBsession_mysql = sessionmaker(bind=engine_mysql)
DBsession_mysql = scoped_session(DBsession_mysql) DBsession_mysql = scoped_session(DBsession_mysql)
DBsession_postgre = sessionmaker(bind=engine_postgre) DBsession_postgre = sessionmaker(bind=engine_postgre)
DBsession_postgre = scoped_session(DBsession_postgre) DBsession_postgre = scoped_session(DBsession_postgre)
# 创建session_mysql对象: # 创建session_mysql对象:
session_mysql = DBsession_mysql() session_mysql = DBsession_mysql()
session_mysql.expire_on_commit = False session_mysql.expire_on_commit = False
session_postgre = DBsession_postgre() session_postgre = DBsession_postgre()
session_postgre.expire_on_commit = False session_postgre.expire_on_commit = False
except Exception as es: except Exception as es:
logger.error("数据库连接失败") logger.error("数据库连接失败")
logger.error(es) logger.error(es)
def str_to_byte(item): def str_to_byte(item):
return bytes(item, encoding='utf8') return bytes(item, encoding='utf8')
def byte_to_str(item): def byte_to_str(item):
return str(item, encoding='utf-8') return str(item, encoding='utf-8')
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment