Upload New File

1 files changed, 22 insertions, 0 deletions

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")
+