webexteams.endpoint() function

Flux 0.125.0+

The webexteams.endpoint() function is a user-contributed function maintained by the package author and can be updated or removed at any time.

The webexteams.endpoint() function returns a function that sends a message that includes data from input rows to a Webex room.

import "contrib/sranka/webexteams"

  url: "",
  token: "token"



Base URL of Webex API endpoint (without a trailing slash). Default is


(Required) Webex API access token.


webexteams.endpoint is a factory function that outputs another function. The output function requires a mapFn parameter.


A function that builds the object used to generate the POST request. Requires an r parameter.

mapFn accepts a table row (r) and returns an object that must include the following fields:

  • roomId
  • text
  • markdown

For more information, see webexteams.message() parameters.


Send the last reported status to 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}**.", 

Package author and maintainer

Github: @sranka
InfluxDB Slack: @sranka

Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.