https://www.npmjs.com/package/pg-copy-streams мне нужно организовать стриминг в базу, но я никак не разберусь как без файлов устроить стриминг строки.. т.е. мне надо открыть коннект с STDIN в базе.. и имея этот коннект туда транслировать записи из скрипта..
https://www.npmjs.com/package/pg-copy-streams мне нужно организовать стриминг в базу, но я никак не разберусь как без файлов устроить стриминг строки.. т.е. мне надо открыть коннект с STDIN в базе.. и имея этот коннект туда транслировать записи из скрипта..
или если я правильно понял.. то эта библиотека создаёт стрим, а мне надо только понять через какую функцию закидывать в этот стрим данные и в нужный момент закрывать стрим?
мне надо пол миллиарда строк как можно быстрее загрузить в базу PostgreSQL) через мульти инсерт долго идёт, т.е. банчи по 8-12к строк сохраняются по 10-50 секунд. Вот как вариант попробовать использовать функцию COPY и с помощью стриминга в базу слать данные