Merge remote-tracking branch 'origin/eta/1.8.4'

services/base_from_python.go

@@ -191,7 +191,7 @@ func getPythonFrontStr() string {
 // @datetime 2024-05-07 18:38:03
 // @return string
 func getPythonFront2Str() string {
-	str := fmt.Sprintf("\nfrom pymongo import MongoClient\nfrom dateutil.tz import tzlocal\n# MongoDB 连接配置\nmongo_config = {\n    'host': '%s',  # 替换为你的 MongoDB 连接字符串\n    'database': '%s',  # 替换为你的数据库名\n    'collection': '%s'  # 替换为你的集合名\n}\n\n# 创建 MongoClient 并连接到数据库\nclient = MongoClient(mongo_config['host'])\nmgo_db = client[mongo_config['database']]\ncollection = mgo_db[mongo_config['collection']]\n\n# 定义时区\nutc_tz = pytz.utc\nlocal_tz = tzlocal()  # 本地时区", utils.PYTHON_MONGO_HOST, utils.PYTHON_MONGO_DATABASE, "edb_data_business")
+	str := fmt.Sprintf("\nfrom pymongo import MongoClient\nfrom dateutil.tz import tzlocal\n# MongoDB 连接配置\nmongo_config = {\n    'host': '%s',  # 替换为你的 MongoDB 连接字符串\n    'database': '%s',  # 替换为你的数据库名\n    'collection': '%s',  # 替换为你的集合名\n    'auth_mechanism': '%s'  # 替换为你的认证机制\n}\n\n# 创建 MongoClient 并连接到数据库\nclient = MongoClient(mongo_config['host'], authMechanism=mongo_config['auth_mechanism'])\nmgo_db = client[mongo_config['database']]\ncollection = mgo_db[mongo_config['collection']]\n\n# 定义时区\nutc_tz = pytz.utc\nlocal_tz = tzlocal()  # 本地时区", utils.PYTHON_MONGO_HOST, utils.PYTHON_MONGO_DATABASE, "edb_data_business", utils.PYTHON_MONGO_AUTH_MECHANISM)
 	return str
 }
 

utils/config.go

@@ -16,13 +16,14 @@ var (
 	MYSQL_URL_GL  string
 	MgoUrlData    string // mongodb数据库连接配置
 
-	PYTHON_MYSQL_HOST     string // python数据库链接主机地址
-	PYTHON_MYSQL_USER     string // python数据库链接账号
-	PYTHON_MYSQL_PASSWD   string // python数据库链接密码
-	PYTHON_MYSQL_DB       string // python数据库链接数据库名
-	PYTHON_MONGO_HOST     string // python链接mongo主机地址
-	PYTHON_MONGO_DATABASE string // python链接mongo的库名
-	PYTHON_PATH           string // python可执行文件地址
+	PYTHON_MYSQL_HOST           string // python数据库链接主机地址
+	PYTHON_MYSQL_USER           string // python数据库链接账号
+	PYTHON_MYSQL_PASSWD         string // python数据库链接密码
+	PYTHON_MYSQL_DB             string // python数据库链接数据库名
+	PYTHON_MONGO_HOST           string // python链接mongo主机地址
+	PYTHON_MONGO_DATABASE       string // python链接mongo的库名
+	PYTHON_MONGO_AUTH_MECHANISM string // python认证机制
+	PYTHON_PATH                 string // python可执行文件地址
 
 	REDIS_CACHE string //缓存地址
 	//Rc          *cache.Cache //redis缓存
@@ -141,8 +142,9 @@ func init() {
 	PYTHON_MYSQL_PASSWD = config["python_mysql_passwd"]
 	PYTHON_MYSQL_DB = config["python_mysql_db"]
 
-	PYTHON_MONGO_HOST = config["python_mongo_host"]   // python链接mongo主机地址
-	PYTHON_MONGO_DATABASE = config["python_mongo_db"] // python链接mongo的库名
+	PYTHON_MONGO_HOST = config["python_mongo_host"]                     // python链接mongo主机地址
+	PYTHON_MONGO_DATABASE = config["python_mongo_db"]                   // python链接mongo的库名
+	PYTHON_MONGO_AUTH_MECHANISM = config["python_mongo_auth_mechanism"] // python链接认证机制
 
 	PYTHON_PATH = config["python_path"]