stream postgres rows to javascript

package.json

{
  "name": "stream-rows",
  "version": "1.0.0",
  "main": "index.js",
  "dependencies": {
    "postgres": "^2.0.0-beta.10"
  }
}

stream-rows.js

const postgres = require("postgres");

const sql = postgres({
  host: process.env.PGHOST,
  database: process.env.PGDATABASE,
  password: process.env.PGPASSWORD,
  username: process.env.PGUSER,
  port: process.env.PGPORT,
  ssl: "prefer",
  max: 2,
  connection: {
    application_name: "script",
  },
  idle_timeout: 30,
});

const delay = (ms) =>
  new Promise((resolve) => {
    setTimeout(resolve, ms);
  });

console.log("streaming rows from twitter table");

const main = async () => {
  await sql`
    SELECT * FROM twitter_accounts
  `.cursor(1, async (row) => {
    console.log(row);
    await delay(2000);
  });
  console.log("done streaming rows");
};

main();