Stream Postgres changes directly to Elasticsearch with Sequin’s Elasticsearch sink.
https://your-es-server:9200
).
api_key
, basic
, or bearer
.
100
, maximum 10 000
).
Auth type | Example header |
---|---|
api_key | Authorization: ApiKey <encoded-key> |
basic | Authorization: Basic <username:password> |
bearer | Authorization: Bearer <token> |
_id
to the concatenation of the primary‑key column values of the Postgres row. Let us know if you need to use a different _id
field.
Because the sink always uses the index
bulk operation, every payload must contain the full document. Partial updates are not supported.
POST /{index_name}/_bulk
Change action | Bulk operation | Behaviour |
---|---|---|
INSERT , UPDATE , READ | index | Creates the document if missing; replaces it otherwise. |
DELETE | delete | Removes the document by _id . |
POST /{index_name}/_bulk
– indexing, replacing, and deleting documents (always used, even for a single document).POST /{index_name}/_search
– invoked by Test Connection in the console to verify connectivity.404
– index not found.401
/ 403
– authentication or authorisation failure.10,000
documents by Sequin. Elasticsearch’s default http.max_content_length
(100 MB) may require smaller batches.index
and delete
bulk operations are issued. Other operations (update
, create
, etc.) are not used.index_name
with routing functions.
Example routing function: