index.mjs

import { InfluxDB } from '@influxdata/influxdb-client'

const client = new InfluxDB({
  url: 'https://eu-central-1-1.aws.cloud2.influxdata.com',
  token: process.env.INFLUX_TOKEN, // julian-station-read
  timeout: 5 * 60 * 1000
})
const queryApi = client.getQueryApi('Filecoin Station')
const query = `
  from(bucket:"station")
    |> range(start: 0, stop: 2024-05-01T00:00:00Z)
`
const counts = {
  rows: 0,
  jobs: 0
}
const status = () => console.error(new Date(), counts)
setInterval(status, 1000).unref()

queryApi.queryRows(query, {
  next (row, tableMeta) {
    const obj = tableMeta.toObject(row)
    delete obj.url
    delete obj.host
    delete obj._start
    delete obj._stop
    delete obj.table
    counts.rows++
    if (obj._measurement === 'jobs-completed' && obj._field === 'value') {
      counts.jobs += obj._value
    }
    console.log(JSON.stringify(obj))
  },
  error: console.error,
  complete: status
})