D4
/
d4-core
mirror of https://github.com/D4-project/d4-core
2
0
Fork 0
Code Issues Releases Wiki Activity

fix: [worker 1] fix config import

gallypette-patch-1
Terrtia 2020-01-22 14:00:18 +01:00
parent 56e7657253
commit 8fa83dd248
No known key found for this signature in database
GPG Key ID: 1E1B1F50D84613D0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/workers/workers_1/worker.py
View File

@ -48,6 +48,7 @@ def compress_file(file_full_path, i=0):
analyser_queue_max_size = analyzer_list_max_default_size analyser_queue_max_size = analyzer_list_max_default_size
redis_server_analyzer.ltrim('analyzer:{}:{}'.format(type, analyzer_uuid), 0, analyser_queue_max_size) redis_server_analyzer.ltrim('analyzer:{}:{}'.format(type, analyzer_uuid), 0, analyser_queue_max_size)
config_loader = ConfigLoader.ConfigLoader()
redis_server_stream = config_loader.get_redis_conn("Redis_STREAM", decode_responses=False) redis_server_stream = config_loader.get_redis_conn("Redis_STREAM", decode_responses=False)
redis_server_metadata = config_loader.get_redis_conn("Redis_METADATA", decode_responses=False) redis_server_metadata = config_loader.get_redis_conn("Redis_METADATA", decode_responses=False)
redis_server_analyzer = config_loader.get_redis_conn("Redis_ANALYZER", decode_responses=False) redis_server_analyzer = config_loader.get_redis_conn("Redis_ANALYZER", decode_responses=False)
@ -59,7 +60,7 @@ if use_default_save_directory:
data_directory = os.path.join(os.environ['D4_HOME'], 'data') data_directory = os.path.join(os.environ['D4_HOME'], 'data')
else: else:
data_directory = config_loader.get_config_str("Save_Directories", "save_directory") data_directory = config_loader.get_config_str("Save_Directories", "save_directory")
config_loader = None
type = 1 type = 1
tcp_dump_cycle = '300' tcp_dump_cycle = '300'