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
有关更多信息，请参阅 函数类型签名。
参数
url
(必需) 发送 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()
此页面是否对您有帮助？
感谢您的反馈！