From bae17b6449700efca0ddf072de2f670853883b4c Mon Sep 17 00:00:00 2001 From: 马泽宇 Date: Mon, 24 Aug 2020 23:18:05 +0800 Subject: Upload New File --- read_policy.py | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 read_policy.py diff --git a/read_policy.py b/read_policy.py new file mode 100644 index 0000000..4e5cb20 --- /dev/null +++ b/read_policy.py @@ -0,0 +1,22 @@ + +from log import save_log, kafka_consumer, clic_client, readIni, Logger + +kafHost, cliHost, policy_table, policy_topic = readIni(0) +logger = Logger("policy") + +try: + client = clic_client(cliHost) +except: + logger.error("clickhouse connect failed") + +try: + consumer_policy = kafka_consumer(policy_topic, kafHost) +except: + logger.error("kafka connect failed") + +for msg in consumer_policy: + try: + save_log(eval(msg.value), policy_table, client) + except: + logger.error("saving error") + -- cgit v1.2.3