http.endpoint() function

http.endpoint() iterates over input data and sends a single POST request per input row to a specficied URL.

This function is designed to be used with monitor.notify().

http.endpoint() outputs a function that requires a mapFn parameter. mapFn is the function that builds the record used to generate the POST request. It accepts a table row (r) and returns a record that must include the following properties:

  • headers
  • data

For information about properties, see

Function type signature
    url: string,
) => (mapFn: (r: A) => {B with headers: C, data: bytes}) => (<-tables: stream[A]) => stream[{A with _sent: string}] where C: Record
For more information, see Function type signatures.



(Required) URL to send the POST reqeust to.


Send an HTTP POST request for each row

import "http"
import "sampledata"

endpoint =
    http.endpoint(url: "")(
        mapfn: (r) =>
                headers: {header1: "example1", header2: "example2"},
                data: bytes(v: "The value is ${r._value}"),
    |> endpoint()

Was this page helpful?

Thank you for your feedback!

Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.