DocumentDB
CertifiedTasks that manage DocumentDB collections with MongoDB-compatible insert, query, update, and delete operations.
Connect to DocumentDB's HTTP API to insert, read, update, and delete collection data. Provide host, database, collection, username, and password; Insert handles one document or up to 10 via documents, Read supports filters or aggregation pipelines with fetchType output handling, and Update/Delete apply MongoDB-style filters with updateMany/deleteMany switches to control scope.
DocumentDB
Tasks that manage DocumentDB collections with MongoDB-compatible insert, query, update, and delete operations.
Connect to DocumentDB's HTTP API to insert, read, update, and delete collection data. Provide host, database, collection, username, and password; Insert handles one document or up to 10 via documents, Read supports filters or aggregation pipelines with fetchType output handling, and Update/Delete apply MongoDB-style filters with updateMany/deleteMany switches to control scope.
tasks
How to use the DocumentDB plugin
Read and write documents in Amazon DocumentDB (MongoDB-compatible) from Kestra flows.
Authentication
Set host (required, the HTTPS endpoint), username (required), and password (required) on every task, along with database and collection. Authentication uses HTTP Basic auth. Store secrets in secrets and apply connection properties globally with plugin defaults.
Tasks
Read queries documents from a collection — optionally set filter (MongoDB-style filter object) and limit/skip for pagination. Use aggregationPipeline instead of filter to run an aggregation (when set, it overrides filter, skip, and limit). Set fetchType (default FETCH) to control output: FETCH returns all rows in rows, FETCH_ONE returns a single row in row, STORE writes to internal storage and returns a uri. The output also includes size.
Insert inserts one or more documents — set either document (a single map) or documents (a list, max 10 per call). The output includes insertedId, insertedIds, and insertedCount.
Update updates documents matching a filter — set update (required, MongoDB update operators such as $set, $inc). Set updateMany: true to update all matches (default false, updates only the first). The output includes matchedCount, modifiedCount, and upsertedId.
Delete deletes documents matching a filter — set deleteMany: true to delete all matches (default false, deletes only the first). The output includes deletedCount.
