Load

yaml
type: "io.kestra.plugin.mongodb.Load"

Examples

yaml
id: mongodb_load
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: load
    type: io.kestra.plugin.mongodb.Load
    connection:
      uri: "mongodb://root:example@localhost:27017/?authSource=admin"
    database: "my_database"
    collection: "my_collection"
    from: "{{ inputs.file }}"

Properties

collection*string

connection*

Definitions

io.kestra.plugin.mongodb.MongoDbConnection

uri*string

database*string

from*string

chunkintegerstring

Default1000

idKeystring

removeIdKeybooleanstring

Defaulttrue

Outputs

deletedCountinteger

Default0

insertedCountinteger

Default0

matchedCountinteger

Default0

modifiedCountinteger

Default0

sizeinteger

Metrics

recordscounter

Unitcount

requests.countcounter

Unitcount

Load

Create automations with Mongodb Load

Generate mock JSON data and send the file to MongoDB

Scrape API in a Python task running in a Docker container and load the JSON document to a MongoDB collection