webexteams.endpoint() 函数
webexteams.endpoint()
是由软件包作者维护的用户贡献函数。
webexteams.endpoint()
返回一个函数,该函数发送一条消息,其中包含来自输入行的数据到 Webex 房间。
用法
webexteams.endpoint
是一个工厂函数,它输出另一个函数。输出函数需要 mapFn
参数。
mapFn
一个构建用于生成 POST 请求的对象的函数。需要一个 r
参数。
mapFn
接受一个表行 (r
) 并返回一个对象,该对象必须包含以下字段
roomId
text
markdown
有关更多信息,请参阅 webexteams.message
参数。
函数类型签名
(
token: string,
?url: string,
) => (
mapFn: (r: A) => {B with text: E, roomId: D, markdown: C},
) => (<-tables: stream[A]) => stream[{A with _sent: string}]
有关更多信息,请参阅 函数类型签名。
参数
url
Webex API 端点的基本 URL(不带尾部斜杠)。默认为 https://webexapis.com
。
token
(必需) Webex API 访问令牌。
示例
将上次报告的状态发送到 Webex Teams
import "contrib/sranka/webexteams"
import "influxdata/influxdb/secrets"
token = secrets.get(key: "WEBEX_API_KEY")
from(bucket: "example-bucket")
|> range(start: -1m)
|> filter(fn: (r) => r._measurement == "statuses")
|> last()
|> tableFind(fn: (key) => true)
|> webexteams.endpoint(token: token)(
mapFn: (r) =>
({
roomId:
"Y2lzY29zcGFyazovL3VzL1JPT00vYmJjZWIxYWQtNDNmMS0zYjU4LTkxNDctZjE0YmIwYzRkMTU0",
text: "",
markdown: "Disk usage is **${r.status}**.",
}),
)()
此页面是否对您有帮助?
感谢您的反馈!