telegram.endpoint() 函数
telegram.endpoint() 是用户贡献的函数，由包作者维护。
telegram.endpoint() 使用表行中的数据向 Telegram 频道发送消息。
用法
telegram.endpoint 是一个工厂函数，它输出另一个函数。输出函数需要 mapFn 参数。
mapFn
一个构建用于生成 POST 请求的对象的函数。需要 r 参数。
mapFn 接受一个表行 (r) 并返回一个对象，该对象必须包含以下字段
channeltextsilent
有关更多信息，请参阅 telegram.message() 参数。
有关更多信息，请参阅 telegram.message 参数。
函数类型签名
(
token: string,
?disableWebPagePreview: A,
?parseMode: B,
?url: string,
) => (
mapFn: (r: C) => {D with text: G, silent: F, channel: E},
) => (<-tables: stream[C]) => stream[{C with _sent: string}]
有关更多信息，请参阅函数类型签名。
参数
url
Telegram 机器人端点的 URL。默认为 https://api.telegram.org/bot。
token
(必需) Telegram 机器人令牌。
parseMode
消息文本的解析模式。默认为 MarkdownV2。
disableWebPagePreview
禁用发送消息中网页链接的预览。默认为 false。
示例
向 Telegram 频道发送严重状态
import "influxdata/influxdb/secrets"
import "contrib/sranka/telegram"
token = secrets.get(key: "TELEGRAM_TOKEN")
endpoint = telegram.endpoint(token: token)
crit_statuses =
from(bucket: "example-bucket")
|> range(start: -1m)
|> filter(fn: (r) => r._measurement == "statuses" and status == "crit")
crit_statuses
|> endpoint(
mapFn: (r) => ({channel: "-12345", text: "Disk usage is **${r.status}**.", silent: true}),
)()
此页内容对您有帮助吗？
感谢您的反馈！