http.endpoint() 函数
http.endpoint() 遍历输入数据，并对每个输入行向指定的 URL 发送单个 POST 请求。
此函数旨在与 monitor.notify() 一起使用。
http.endpoint() 输出一个需要 mapFn 参数的函数。mapFn 是构建用于生成 POST 请求的记录的函数。它接受一个表格行 (r) 并返回一个必须包括以下属性的记录：
headersdata
有关属性的信息，请参阅 http.post。
函数类型签名
(
url: string,
) => (mapFn: (r: A) => {B with headers: C, data: bytes}) => (<-tables: stream[A]) => stream[{A with _sent: string}] where C: Record
有关更多信息，请参见 Function type signatures。
参数
网址
(必填) 发送POST请求的URL。
示例
对每一行发送一个HTTP POST请求
import "http"
import "sampledata"
endpoint =
http.endpoint(url: "http://example.com/")(
mapfn: (r) =>
({
headers: {header1: "example1", header2: "example2"},
data: bytes(v: "The value is ${r._value}"),
}),
)
sampledata.int()
|> endpoint()