Ingest

Source: src/AWS/OSIS/Ingest.ts

Runtime binding for the osis:Ingest data plane.

Sends events into the bound Pipeline’s ingest endpoint — the pipeline’s actual data plane. There is no SDK operation for ingestion; each batch is a SigV4-signed HTTP POST (service "osis") to the pipeline’s ingest endpoint URL, made with the host Function’s own credentials. The endpoint and pipeline name are injected from the binding; pass the source path configured on the pipeline’s http source and the batch of events. Provide the implementation with Effect.provide(AWS.OSIS.IngestHttp).

Ingesting Data

// init — bind the data plane to the pipeline
const ingest = yield* AWS.OSIS.Ingest(pipeline);

// runtime — path must match the pipeline config's http source path
yield* ingest({
  path: "/logs/ingest",
  events: [{ message: "hello", level: "info" }],
});