darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2025-12-13 00:32:16 -05:00
Code Issues Packages Projects Releases Wiki Activity

change to send 3 messages per second

Browse Source
This commit is contained in:
Kenneth Kehl
2024-12-23 13:51:21 -08:00
parent a820510842
commit 85c5268eae
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/celery/tasks.py
View File

@@ -78,14 +78,16 @@ def process_job(job_id, sender_id=None):
# notify-api-1495 we are going to sleep periodically to give other # notify-api-1495 we are going to sleep periodically to give other
# jobs running at the same time a chance to get some of their messages # jobs running at the same time a chance to get some of their messages
# sent. Sleep for 40 seconds after every 100 sends, which gives us throughput # sent. Sleep for 1 second after every 3 sends, which gives us throughput
# of about 9000 per hour and would keep the queue clear assuming only one sender. # of about 3600*3 per hour and would keep the queue clear assuming only one sender.
# It will also hopefully eliminate throttling when we send messages which we are
# currently seeing.
count = 0 count = 0
for row in recipient_csv.get_rows(): for row in recipient_csv.get_rows():
process_row(row, template, job, service, sender_id=sender_id) process_row(row, template, job, service, sender_id=sender_id)
count = count + 1 count = count + 1
if count % 100 == 0: if count % 3 == 0:
sleep(40) sleep(1)
# End point/Exit point for message send flow. # End point/Exit point for message send flow.
job_complete(job, start=start) job_complete(job, start=start)