文档文档

discord.endpoint() 函数

discord.endpoint() 是用户贡献的函数,由包作者维护。

discord.endpoint() 使用 Discord webhook 和表行数据向 Discord 频道发送单条消息。

用法

discord.endpoint 是一个工厂函数,输出另一个函数。输出函数需要 mapFn 参数。

mapFn

一个构建用于生成 Discord webhook 请求的记录的函数。需要一个 r 参数。

mapFn 接受一个表行 (r) 并返回一个记录,该记录必须包含以下字段

  • content

有关更多信息,请参阅 discord.send() content 参数。

函数类型签名
(
    username: A,
    webhookID: string,
    webhookToken: string,
    ?avatar_url: B,
) => (mapFn: (r: C) => {D with content: E}) => (<-tables: stream[C]) => stream[{C with _sent: string}]

有关更多信息,请参阅 函数类型签名

参数

webhookToken

(必填) Discord webhook 令牌

webhookID

(必填) Discord webhook ID

username

(必填) 覆盖 Discord webhook 的默认用户名。

avatar_url

覆盖 Discord webhook 的默认头像。

示例

向 Discord 频道发送关键状态

import "influxdata/influxdb/secrets"
import "contrib/chobbs/discord"

discordToken = secrets.get(key: "DISCORD_TOKEN")
endpoint =
    telegram.endpoint(webhookToken: discordToken, webhookID: "123456789", username: "critBot")

crit_statuses =
    from(bucket: "example-bucket")
        |> range(start: -1m)
        |> filter(fn: (r) => r._measurement == "statuses" and status == "crit")

crit_statuses
    |> endpoint(mapFn: (r) => ({content: "The status is critical!"}))()

此页内容是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。您可以继续像现在一样使用它,而无需更改任何代码。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速开始。更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速的最新数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。InfluxDB 3 Enterprise 构建于 Core 的基础上,增加了高可用性、读取副本、增强的安全性以及数据压缩,从而实现更快的查询和优化的存储。InfluxDB 3 Enterprise 的免费层可供非商业家庭或业余爱好者使用。

有关更多信息,请查看