nodejs с экспресс-ответом HTTP

Question

У меня есть следующий тестовый код:

const compression = require('compression');
const bodyParser = require('body-parser')
const cors = require('cors')
const { pool, connectionString } = require('./config')
const { handleError, ErrorHandler } = require('./error')

const app = express()
app.use(bodyParser.json())
app.use(bodyParser.urlencoded({ extended: true }))
app.use(cors())
app.use(compression());
const getEvents = (request, response) => {
    pool.connect((err, client, release) => {
        if (err) {
            throw new ErrorHandler(500, err.stack);
        }
        if(!request.query.FromTime){
            throw new ErrorHandler(400, 'Required paramter FromTime is missing.');
        }
        if(!request.query.ToTime){
            throw new ErrorHandler(400, 'Required paramter ToTime is missing.');
        }
        let fromtime = request.query.FromTime
        let totime = request.query.ToTime
        console.log("FromTime: ",fromtime," ToTime: ",totime);
        let query = 'SELECT data FROM logs WHERE time BETWEEN '+fromtime+' AND '+totime+' ORDER BY time DESC';
        console.log(query)
        var stream = client.query(query, (error, results) => {
            if (error) {
                throw new ErrorHandler(500,error);
            }
            response.status(200).json(results.rows)
        })
    })
}
...
app
  .route('/events')
  // GET endpoint
  .get(getEvents)
  // POST endpoint
  .post(addEvent)

app.use((err, req, res, next) => {
  handleError(err, res);
});
// Start server
app.listen(process.env.PORT || 3002, () => {
  console.log(`Server listening`)
})

Я пытался получить это для потоковой передачи данных, но безуспешно. Я пробовал pg-query-stream, с querystream, но в итоге вывел следующую ошибку, когда попытался

var stream = client.query(new QueryStream(query));
stream.pipe(response);

_http_outgoing.js: 607 бросить новый ERR_INVALID_ARG_TYPE ('первый аргумент', ^

TypeError [ERR_INVALID_ARG_TYPE]: первый аргумент должен быть одним из типа string или Buffer. Полученный объект типа в write_ (_http_outgoing.js: 607: 11) в ServerResponse.write (_http_outgoing.js: 579: 10) вServerResponse.write (/usr/src/app/node_modules/compression/index.js:89:18) в PgQueryStream.ondata (_stream_readable.js: 705: 22) в PgQueryStream.emit (events.js: 193: 13) вaddChunk (_stream_readable.js: 295: 12) в readableAddChunk (_stream_readable.js: 276: 11) в PgQueryStream.Readable.push (_stream_readable.js: 231: 10) в cursor.read (/ usr / src / app / node_modules /pg-query-stream / index.js: 55: 14) в Immediate.setImmediate (/usr/src/app/node_modules/pg-cursor/index.js:91:7)

Answer 1

поток ответа не поддерживается объектным режимом по умолчанию. Просто попробуйте как в документах

const JSONStream = require('JSONStream')
stream.pipe(JSONStream.stringify()).pipe(response)