pino-http-send

import { createWriteStream } from 'pino-http-send'; import pino from 'pino'; import http from 'http'; // 1. Setup a dummy HTTP server to receive logs (your actual log ingestion endpoint) const server = http.createServer((req, res) => { if (req.url === '/logs' && req.method === 'POST') { let body = ''; req.on('data', (chunk) => { body += chunk.toString(); }); req.on('end', () => { try { console.log(`\n--- Received Batch (${req.headers['content-type']}) ---\n`); if (req.headers['content-type']?.includes('application/json')) { console.log(JSON.parse(body).logs); // 'json' bodyType wraps logs in { logs: [...] } } else { console.log(body); // 'ndjson' is raw new-line delimited JSON } console.log(`--- End Batch ---\n`); res.writeHead(200, { 'Content-Type': 'application/json' }); res.end(JSON.stringify({ status: 'ok', receivedLogsCount: body.split('\n').filter(Boolean).length })); } catch (e) { console.error('Error parsing received logs:', e); res.writeHead(400).end('Bad Request'); } }); } else { res.writeHead(404).end('Not Found'); } }); server.listen(3000, () => { console.log('Dummy log server listening on http://localhost:3000'); console.log('Sending logs via pino-http-send...'); // 2. Configure pino-http-send as a Pino destination const pinoSendStream = createWriteStream({ url: 'http://localhost:3000/logs', method: 'POST', bodyType: 'json', // or 'ndjson' batchSize: 2, // Send every 2 logs timeout: 1000, // or flush after 1 second if batch not full log: true, // Enable internal logging for pino-http-send itself headers: { 'X-Custom-Header': 'pino-test' } }); // 3. Create a Pino logger instance using the pino-http-send stream const logger = pino(pinoSendStream); let count = 0; const interval = setInterval(() => { logger.info({ id: ++count, service: 'my-app', event: 'data_processed', timestamp: new Date().toISOString() }); if (count >= 5) { clearInterval(interval); logger.flush(); // Ensure any buffered logs are sent setTimeout(() => { server.close(() => console.log('Dummy server closed. Exiting.')); }, 2000); // Give time for the last batch to be sent } }, 500); });