Я интегрирую продукт облачной платформы mdm, написанный на Java, с mongodb. Интеграция должна иметь возможность обрабатывать объемные данные (миллиарды записей Json) и вставлять записи в mongo. Продукт обрабатывает ввод и предоставляет его в качестве входного потока. Я использую драйвер Java для mongo для выполнения этой операции: 1) Разбор входного потока в строку Json 2) Разбор строки Json в вставку документа выполняется с использованием пользовательской логики пакетной и массовой записи драйвера mongo.
ОднакоЯ хочу избежать преобразования входного потока в строку. Есть ли способ, с помощью которого мы можем выполнить запись в монго, используя входной поток.
Примечание: 1) Я понимаю, что для драйвера mongo Java требуется, чтобы вход был в фирме объекта Document. 2) Я также рассмотрел реактивные потоки для драйвера Java для mongo и вижу, что он также требует ввода только для Document 3. ) Код интеграции будет работать на облачной платформе mdm, которая поддерживает только языки Java или JVM