no message

Pyspark_job/utils/templates.py

@@ -31,6 +31,7 @@ from pyspark.sql import Window
 from utils.common_util import CommonUtil
 import subprocess
 import requests
+from db_util import get_redis_h14
 
 
 class Templates(object):
@@ -94,7 +95,7 @@ class Templates(object):
         self.test_flag = 'normal'
         self.beginning_offsets_dict = {}  # history消费时, 初始的偏移量
         # redis连接对象--用来锁定--解决并发
-        self.client = redis.Redis(host='192.168.10.224', port=6379, db=9, password='xA9!wL3pZ@q2')
+        self.client = get_redis_h14()
 
     def create_spark_object(self, app_name=None):
         if self.topic_name != '':