文档文档

pushbullet.endpoint() 函数

pushbullet.endpoint() 创建 Pushbullet API 的端点,并发送类型为 note 的通知。

用法

pushbullet.endpoint() 是一个工厂函数,它输出另一个函数。输出函数需要一个 mapFn 参数。

mapFn

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

mapFn 接受一个表行 (r) 并返回一个记录,该记录必须包含以下属性(如 pushbullet.pushNote() 中定义的那样)

  • 标题
  • 文本
函数类型签名
(
    ?token: A,
    ?url: string,
) => (mapFn: (r: B) => {C with title: E, text: D}) => (<-tables: stream[B]) => stream[{B with _sent: string}]

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

参数

url

PushBullet API 端点 URL。默认为 "https://api.pushbullet.com/v2/pushes"

token

Pushbullet API 令牌字符串。默认为 ""

示例

向 Pushbullet 发送推送通知

import "pushbullet"
import "influxdata/influxdb/secrets"

token = secrets.get(key: "PUSHBULLET_TOKEN")

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

crit_statuses
    |> pushbullet.endpoint(token: token)(
        mapFn: (r) =>
            ({
                title: "${r.component} is critical",
                text: "${r.component} is critical. {$r._field} is {r._value}.",
            }),
    )()

此页内容对您有帮助吗?

感谢您的反馈!


Flux 的未来

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

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

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

有关更多信息,请查看