Как это работает
Чтобы данные из Databricks автоматически попадали в Pipedrive, достаточно готового сценария — без выгрузок руками.
- Запуск: Каждые 2 минуты
- Затем: Получить строки из таблицы
- Проверка: Если устарело
- Если да — Удалить файл из векторного хранилища
- Затем: Отметить строку как удаленную
- Если нет — Filter новые файлы
- Проверка: Обработать по одному
- Проверка: Маршрутизировать по источнику файла
- Если да — Скачать из Google Drive
- Затем: Загрузить файл в OpenAI
- Затем: Добавить файл в векторное хранилище
- Затем: Подождать 30 секунд
- Затем: Опросить статус файла в векторном хранилище
- Проверка: Маршрутизировать по статусу эмбеддинга
- Если да — Отметить строку как активную
- Если нет — Отметить строку как ошибку
- Если нет — Скачать из S3
- Если нет — Скачать через HTTP
Эту интеграцию Databricks и Pipedrive можно запустить в Scriptera: опишите задачу словами — сценарий соберут, запустят и будут следить, чтобы он работал.