Перейти к основному содержимому

03.02 Интеграция с Mongo DB Atlas

import { MongoClient } from 'mongodb';

export default async function run({execution_id, input, data}) {

// Строка подключения к MongoDB
// Структура:
// mongodb+srv://USERNAME:PASSWORD@CLUSTER_ADDRESS/DATABASE
// USERNAME: имя пользователя для аутентификации
// PASSWORD: пароль для аутентификации
// CLUSTER_ADDRESS: адрес вашего кластера MongoDB
// DATABASE: используемая по умолчанию база данных (необязательно)
const connectionString = 'mongodb+srv://USERNAME:PASSWORD@CLUSTER_ADDRESS/DATABASE';

// Подключение к клиенту MongoDB
const client = await MongoClient.connect(
connectionString,
{ useNewUrlParser: true, useUnifiedTopology: true } // Опции для подключения
);

// Выбор базы данных 'parsing-m' и коллекции 'apps'
const coll = client.db('parsing-m').collection('apps');

// Поиск последних 3 записей, где поле processed не равно true
const filter = {processed:{$ne: true}};
// Сортировка по полю "sort" в порядке убывания (замените "sort" на реальное имя поля)
const cursor = coll.find(filter).sort({"sort": -1}).limit(3);

// Преобразование курсора в массив для получения результата
const result = await cursor.toArray();

// Закрытие соединения с клиентом MongoDB
await client.close();

// Возврат результата
return result;
}