MongoDB
Запросы, вставка, обновление и агрегация в MongoDB из процессов Pailot
MongoDB — документоориентированная база данных. Блок подключается к серверу и работает с коллекциями: поиск, вставка, обновление, удаление, агрегация и обзор схемы.
С MongoDB в Pailot вы можете:
- Искать документы (
find) с фильтром, лимитом и сортировкой в JSON
- Вставлять один или несколько документов
- Обновлять по фильтру, в том числе upsert и сразу несколько
- Удалять по фильтру
- Запускать aggregation pipeline
- Смотреть базы, коллекции и индексы
Параметры подключения (хост, порт, база, пользователь) задают в блоке. SSL (Secure Sockets Layer — шифрование соединения) — режимы disabled, required, preferred.
Блок ставят на холст как отдельный шаг или прикрепляют к агенту.
Операция find по коллекции MongoDB.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Да | Имя базы |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
collection | string | Да | Имя коллекции |
query | string | Нет | Фильтр запроса — JSON-строка |
limit | number | Нет | Максимум документов |
sort | string | Нет | Сортировка — JSON-строка |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
documents | array | Документы из запроса |
documentCount | number | Сколько документов вернулось |
Вставить документы в коллекцию.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Да | Имя базы |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
collection | string | Да | Имя коллекции |
documents | array | Да | Документы для вставки |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
documentCount | number | Сколько документов вставлено |
insertedId | string | ID вставленного документа (одна вставка) |
insertedIds | array | ID вставленных документов (несколько) |
Обновить документы в коллекции.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Да | Имя базы |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
collection | string | Да | Имя коллекции |
filter | string | Да | Критерий отбора — JSON-строка |
update | string | Да | Операции обновления — JSON-строка |
upsert | boolean | Нет | Создать документ, если не найден |
multi | boolean | Нет | Обновить несколько документов |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
matchedCount | number | Сколько документов подошло под фильтр |
modifiedCount | number | Сколько документов изменено |
documentCount | number | Всего затронутых документов |
insertedId | string | ID вставленного документа (если сработал upsert) |
Удалить документы из коллекции.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Да | Имя базы |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
collection | string | Да | Имя коллекции |
filter | string | Да | Критерий отбора — JSON-строка |
multi | boolean | Нет | Удалить несколько документов |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
deletedCount | number | Сколько документов удалено |
documentCount | number | Всего затронутых документов |
Выполнить aggregation pipeline MongoDB.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Да | Имя базы |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
collection | string | Да | Имя коллекции |
pipeline | string | Да | Конвейер агрегации — JSON-строка |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
documents | array | Документы из агрегации |
documentCount | number | Сколько документов вернулось |
Обзор базы MongoDB: базы, коллекции и индексы.
| Параметр | Тип | Обязательный | Описание |
|---|
host | string | Да | Имя хоста или IP сервера MongoDB |
port | number | Да | Порт сервера (по умолчанию 27017) |
database | string | Нет | Имя базы (если не задано — список всех баз) |
username | string | Нет | Имя пользователя MongoDB |
password | string | Нет | Пароль |
authSource | string | Нет | База для аутентификации |
ssl | string | Нет | Режим SSL: disabled, required, preferred |
| Параметр | Тип | Описание |
|---|
message | string | Сообщение о статусе операции |
databases | array | Имена баз |
collections | array | Коллекции: имя, тип, число документов и индексы |
