You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

32 lines
633 B
Python

"""
Format the alert message.
"""
import asyncio
from typing import (
Any,
NoReturn
)
def format_alert(
alert: dict[str, Any]
)->str:
"""
Format an alert in json format to a nice string.
"""
return str(alert)
async def format_alerts(
alert_queue: asyncio.Queue[dict[str,Any]],
message_queue: asyncio.Queue[str]
)->NoReturn:
"""
Read alerts from alert_queue, format them, and put them in message_queue.
"""
while True:
alert = await alert_queue.get()
message = format_alert(alert)
await message_queue.put(message)
alert_queue.task_done()