Documentdbquery

flowtask.components.DocumentDBQuery

DocumentDBQuery

DocumentDBQuery(loop=None, job=None, stat=None, **kwargs)

Bases: DocumentDBSupport, TemplateSupport, FlowComponent

DocumentDBQuery.

DocumentDBQuery is a component that interacts with a DocumentDB database using pymongo.

Returns json-object representation of the query result.

Example:

```yaml
DocumentDBQuery:
  schema: networkninja
  tablename: batches
  query:
    data.metadata.type: form_data
    data.metadata.timestamp:
      $gte: 1743670800.0
      $lte: 1743681600.999999
```

start async

start(**kwargs)

start.

Start the DocumentDBQuery component.