def __init__(self, request_data_dic):
    self.job_name = lowDefine.SELF_POLICY_NAME
    self.requestDataDic = request_data_dic
    self.requestID = request_data_dic['requestID']
    self.fileID = request_data_dic['fileID']
    self.failCnt = request_data_dic['failCnt']
    self.env = request_data_dic['env']
    self.targetClusters = self.env['targetClusters']
    self.sourceCluster = self.env['option']['sourceCluster']
    self.sourceNode = self.env['option']['sourceNode']
    self.sharedClusters = self.get_shared_clusters()
    self.producer = KafkaProducer(acks=0, compression_type='gzip', bootstrap_servers=[lowDefine.KAFKA_SERVER_URL], value_serializer=(lambda x: dumps(x).encode('utf-8')))
def __init__(self, request_data_dic):
    self.job_name = lowDefine.SELF_POLICY_NAME
    self.requestDataDic = request_data_dic
    self.requestID = request_data_dic['requestID']
    self.fileID = request_data_dic['fileID']
    self.failCnt = request_data_dic['failCnt']
    self.env = request_data_dic['env']
    self.targetClusters = self.env['targetClusters']
    self.sourceCluster = self.env['option']['sourceCluster']
    self.sourceNode = self.env['option']['sourceNode']
    self.sharedClusters = self.get_shared_clusters()
    self.producer = KafkaProducer(acks=0, compression_type='gzip', bootstrap_servers=[lowDefine.KAFKA_SERVER_URL], value_serializer=(lambda x: dumps(x).encode('utf-8')))