Yes, That's the correct use case. Will this work with the DataStream API? UDFs are for the Table API, correct? Is there a custom sink that can be applied? Such as this Fraud Detection example [1]. But in this use case instead of sending the alert to a log it sends the message to a webhook?
[1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/try-flink/datastream/ On Mon, Dec 13, 2021 at 8:25 PM Caizhi Weng <tsreape...@gmail.com> wrote: > Hi! > > Could you please elaborate more on your use case? Do you want to check the > records in a data stream and if some condition is met then send an alert? > > If that is the case, you can use a UDF for checking and sending alerts. > See [1] for detailed explanation about UDF. > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/functions/udfs/ > > Robert Cullen <cinquate...@gmail.com> 于2021年12月14日周二 04:08写道： > >> Hello, >> >> I'm looking for some guidance on how to send alert notifications from a >> DataStream to a Slack channel and possibly other alerting tools (ie. AWS >> sns, mattermost) >> >> -- >> Robert Cullen >> 240-475-4490 >> > -- Robert Cullen 240-475-4490
