pangea
/
django-orchestra
7
0
Fork 0
Code Issues 1 Pull Requests 2 Packages Projects Releases Wiki Activity

lists traffic Multiply bytes sent by receipts

This commit is contained in:
Jorge Pastor 2024-07-11 19:20:20 +02:00
parent e15d2acd13
commit 2e99b8bccd
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
orchestra/contrib/lists/backends.py
View File

@ -255,8 +255,13 @@ class MailmanTraffic(ServiceMonitor):
for postlog in postlogs: for postlog in postlogs:
try: try:
with open(postlog, 'r') as postlog: with open(postlog, 'r') as postlog:
recps_dict = {{}}
for line in postlog.readlines(): for line in postlog.readlines():
line = line.split() line = line.split()
if 'recips,' in line:
__, __, __, __, __, id, __, __, list_name, __, recps = line[:11]
recps_dict[id] = recps
continue
if not 'bytes' in line: if not 'bytes' in line:
continue continue
month, day, time, year, __, __, __, __, list_name, __, addr, size = line[:12] month, day, time, year, __, __, __, __, list_name, __, addr, size = line[:12]
@ -268,22 +273,14 @@ class MailmanTraffic(ServiceMonitor):
else: else:
date = year + months[month] + day + time.replace(':', '') date = year + months[month] + day + time.replace(':', '')
if list[0] < int(date) < end_date: if list[0] < int(date) < end_date:
list[2] += int(size) if id in recps_dict:
list[2] += int(size) * int(recps_dict[id])
except IOError as e: except IOError as e:
sys.stderr.write(str(e)+'\\n') sys.stderr.write(str(e)+'\\n')
for list_name, opts in lists.items(): for list_name, opts in lists.items():
__, object_id, size = opts __, object_id, size = opts
if size:
cmd = f'runuser -u mailman3 -- /opt/mailman/venv/bin/mailman members {{list_name}}@{default_domain} | wc -l'
try:
ps = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
subscribers = ps.communicate()[0].strip()
size *= int(subscribers)
sys.stderr.write("%s %s*%s traffic*subscribers\\n" % (object_id, size, int(subscribers)))
except:
pass
print(object_id, size) print(object_id, size)
""").format(**context) """).format(**context)
) )