llm-app

1
import logging
2

3
import pathway as pw
4
import requests
5

6
logfun = logging.info
7

8

9
def send_slack_alerts(
10
    message: pw.ColumnReference, slack_alert_channel_id, slack_alert_token
11
):
12
    def send_slack_alert(key, row, time, is_addition):
13
        if not is_addition:
14
            return
15
        alert_message = row[message.name]
16
        logfun(alert_message)
17
        requests.post(
18
            "https://slack.com/api/chat.postMessage",
19
            data="text={}&channel={}".format(alert_message, slack_alert_channel_id),
20
            headers={
21
                "Authorization": "Bearer {}".format(slack_alert_token),
22
                "Content-Type": "application/x-www-form-urlencoded",
23
            },
24
        ).raise_for_status()
25

26
    pw.io.subscribe(message._table, send_slack_alert)
27