github/kubeinvaders
1
0
Fork 0
mirror of https://github.com/lucky-sideburn/kubeinvaders.git synced 2026-08-23 21:46:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Eugenio Marzo
2022-10-29 09:43:26 +02:00
parent 5cace1f198
commit dc59b1c819
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/logs_loop/start.py
+16 -14
View File
@@ -72,23 +72,25 @@ api_instance = client.CoreV1Api()
batch_api = client.BatchV1Api()
namespace = "kubeinvaders"
for key in r.scan_iter("logs_enabled:*"):
if r.get(key) == "1":
while True:
logging.info(f"Looking for Redis keys logs_enabled:*")
for key in r.scan_iter("logs_enabled:*"):
if r.get(key) == "1":
logid = key.split(":")[1]
logging.info(f"Found key {key} and it is enabled!")
logid = key.split(":")[1]
if r.exists(f"log_pod_regex:{logid}"):
logging.info(f"[logid:{logid}] The Redis key log_pod_regex exists...")
else:
logging.info(f"[logid:{logid}] The Redis key log_pod_regex does NOT exists...")
r.set(f"log_pod_regex:{logid}", '{"pod":".*", "namespace":".*", "labels":".*", "annotations":".*"}')
if r.exists(f"log_pod_regex:{logid}"):
logging.info(f"[logid:{logid}] The Redis key log_pod_regex exists...")
else:
logging.info(f"[logid:{logid}] The Redis key log_pod_regex does NOT exists...")
r.set(f"log_pod_regex:{logid}", '{"pod":".*", "namespace":".*", "labels":".*", "annotations":".*"}')
if r.exists(f"logs_enabled:{logid}"):
logging.info(f"[logid:{logid}] The Redis key logs_enabled exists...")
else:
logging.info(f"[logid:{logid}]The Redis key logs_enabled does NOT exists...")
if r.exists(f"logs_enabled:{logid}"):
logging.info(f"[logid:{logid}] The Redis key logs_enabled exists...")
else:
logging.info(f"[logid:{logid}]The Redis key logs_enabled does NOT exists...")
while True:
if not r.exists("log_cleaner:{logid}"):
if pathlib.Path(f"/var/www/html/chaoslogs-{logid}.html").exists():
os.remove(f"/var/www/html/chaoslogs-{logid}.html")
@@ -204,4 +206,4 @@ for key in r.scan_iter("logs_enabled:*"):
logging.info(e)
except ApiException as e:
logging.info(e)
time.sleep(0.5)
time.sleep(0.5)