matitos/matitos_news
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Notifications, info and warning, try catch

Browse Source
This commit is contained in:
Luciano Gervasoni
2025-09-09 22:06:23 +02:00
parent 24510d26e2
commit f44b784715
1 changed files with 118 additions and 110 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app_urls/fetcher/src/notifier.py
View File

@@ -4,8 +4,11 @@ from ..models import Urls, Source, Search, UrlContent, UrlsSourceSearch, UrlsDup
from django.db.models import Count from django.db.models import Count
import requests import requests
import os import os
from .logger import get_logger
logger = get_logger()
def notify_telegram_info(last_hours, channel="INFO"): def notify_telegram_info(last_hours, channel="INFO"):
try:
start_date = timezone.now() - timedelta(hours=last_hours) start_date = timezone.now() - timedelta(hours=last_hours)
# Count the number of URLs grouped by status within the date range # Count the number of URLs grouped by status within the date range
@@ -53,9 +56,12 @@ def notify_telegram_info(last_hours, channel="INFO"):
# POST # POST
response = requests.post(url, params=params) response = requests.post(url, params=params)
except Exception as e:
logger.info("Exception while notifying status: {}".format(str(e)))
def notify_telegram_warning(last_hours, channel="WARNING"): def notify_telegram_warning(last_hours, channel="WARNING"):
try:
# Message appending logic # Message appending logic
message = "" message = ""
@@ -135,6 +141,8 @@ def notify_telegram_warning(last_hours, channel="WARNING"):
# POST # POST
response = requests.post(url, params=params) response = requests.post(url, params=params)
except Exception as e:
logger.info("Exception while notifying status: {}".format(str(e)))
def notify_telegram(last_hours=12): def notify_telegram(last_hours=12):