http.endpoint() function

http.endpoint() iterates over input data and sends a single POST request per input row to a specified 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 request 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!

The future of Flux

Flux is going into maintenance mode. You can continue using it as you currently are without any changes to your code.

Read more