thomas/multiarch-docker-images
1
0
Fork 0
mirror of https://github.com/napnap75/multiarch-docker-images.git synced 2026-09-25 20:31:52 +02:00
Code Issues Projects Releases Wiki Activity

Removed duplicate notification of logs that are outside the specified time range.

Browse Source
This commit is contained in:
thomas
2026-08-31 22:23:04 +02:00
parent a5337c3d29
commit a3402c85d6
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
log-alert/fetchers/parseable.py
+8 -6
View File
@@ -41,23 +41,25 @@ class ParseableLogFetcher(LogFetcher):
if labelNum > 0: if labelNum > 0:
query += ' AND ' query += ' AND '
query += f'log LIKE \'%{filters["text"]}%\'' query += f'log LIKE \'%{filters["text"]}%\''
logger.debug(f"Executing Parseable query: {query}")
payload = { payload = {
"query": query, "query": query,
"startTime": datetime.datetime.fromtimestamp(start_time).strftime("%Y-%m-%dT%H:%M:%SZ"), "startTime": datetime.datetime.fromtimestamp(start_time).strftime("%Y-%m-%dT%H:%M:%SZ"),
"endTime": datetime.datetime.fromtimestamp(end_time).strftime("%Y-%m-%dT%H:%M:%SZ") "endTime": datetime.datetime.fromtimestamp(end_time).strftime("%Y-%m-%dT%H:%M:%SZ")
} }
logger.debug(f"Executing Parseable query: {payload}")
try: try:
response = requests.post(f"{self.url}/api/v1/query", json=payload, auth=(self.user, self.password), headers = { "Content-Type": "application/json" }) response = requests.post(f"{self.url}/api/v1/query", json=payload, auth=(self.user, self.password), headers = { "Content-Type": "application/json" })
response.raise_for_status() response.raise_for_status()
data = response.json() data = response.json()
logs = [] logs = []
for item in data: for item in data:
logs.append({ timestamp = int(datetime.datetime.strptime(item.get("p_timestamp"), "%Y-%m-%dT%H:%M:%S.%f").replace(tzinfo=datetime.timezone.utc).timestamp())
"timestamp": item.get("p_timestamp"), if timestamp >= start_time and timestamp < end_time:
"log": item.get("log"), logs.append({
"labels": {k: v for k, v in item.items() if k not in ["p_timestamp", "log"]} "timestamp": item.get("p_timestamp"),
}) "log": item.get("log"),
"labels": {k: v for k, v in item.items() if k not in ["p_timestamp", "log"]}
})
return logs return logs
except requests.exceptions.RequestException as e: except requests.exceptions.RequestException as e:
logger.error(f"Error fetching logs from Parseable: {e}") logger.error(f"Error fetching logs from Parseable: {e}")