docs: node wizzard async

Author: Sciator

src/homepageExperience/components/steps/nodejs/ExecuteAggregateQuery.tsx

@@ -29,18 +29,19 @@ fluxQuery = \`from(bucket: "${bucket}")
  |> filter(fn: (r) => r._measurement == "measurement1")
  |> mean()\`
 
-queryClient.queryRows(fluxQuery, {
-  next: (row, tableMeta) => {
-    const tableObject = tableMeta.toObject(row)
+async function iterateRowsAggregated() {
+  for await (const {values, tableMeta} of queryClient.iterateRows(fluxQuery)) {
+    const tableObject = tableMeta.toObject(values)
     console.log(tableObject)
-  },
-  error: (error) => {
-    console.error('\\nError', error)
-  },
-  complete: () => {
+  }
+}
+iterateRowsAggregated()
+  .then(() => {
     console.log('\\nSuccess')
-  },
-})`
+  })
+  .catch(error => {
+    console.error('\\nError', error)
+  })`
 
   return (
     <>

src/homepageExperience/components/steps/nodejs/ExecuteQuery.tsx

@@ -22,18 +22,19 @@ let fluxQuery = \`from(bucket: "${bucket}")
  |> range(start: -10m)
  |> filter(fn: (r) => r._measurement == "measurement1")\`
 
-queryClient.queryRows(fluxQuery, {
-  next: (row, tableMeta) => {
-    const tableObject = tableMeta.toObject(row)
+async function iterateRows() {
+  for await (const {values, tableMeta} of queryClient.iterateRows(fluxQuery)) {
+    const tableObject = tableMeta.toObject(values)
     console.log(tableObject)
-  },
-  error: (error) => {
-    console.error('\\nError', error)
-  },
-  complete: () => {
+  }
+}
+iterateRows()
+  .then(() => {
     console.log('\\nSuccess')
-  },
-})`
+  })
+  .catch(error => {
+    console.error('\\nError', error)
+  })`
 
   return (
     <>

src/writeData/clients/Javascript/execute.example

@@ -1,17 +1,19 @@
 const queryApi = client.getQueryApi(org)
 
 const query = `<%= query %>`
-queryApi.queryRows(query, {
-  next: (row, tableMeta) => {
-    const o = tableMeta.toObject(row)
+
+async function iterateRows() {
+  for await (const {values, tableMeta} of queryClient.iterateRows(query)) {
+    const o = tableMeta.toObject(values)
     console.log(`${o._time} ${o._measurement}: ${o._field}=${o._value}`)
-  },
-  error: (error) => {
-    console.error(error)
-    console.log('Finished ERROR')
-  },
-  complete: () => {
-    console.log('Finished SUCCESS')
-  },
-})
+  }
+}
+
+iterateRows()
+  .then(() => {
+    console.log('\\nSuccess')
+  })
+  .catch(error => {
+    console.error('\\nError', error)
+  })
 

src/writeData/clients/Javascript/executeFull.example

@@ -9,16 +9,18 @@ const client = new InfluxDB({url: '<%= server %>', token: token})
 const queryApi = client.getQueryApi(org)
 
 const query = `<%= query %>`
-queryApi.queryRows(query, {
-  next: (row, tableMeta) => {
-    const o = tableMeta.toObject(row)
+
+async function iterateRows() {
+  for await (const {values, tableMeta} of queryClient.iterateRows(query)) {
+    const o = tableMeta.toObject(values)
     console.log(`${o._time} ${o._measurement}: ${o._field}=${o._value}`)
-  },
-  error: (error) => {
-    console.error(error)
-    console.log('Finished ERROR')
-  },
-  complete: () => {
-    console.log('Finished SUCCESS')
-  },
-})
+  }
+}
+
+iterateRows()
+  .then(() => {
+    console.log('\\nSuccess')
+  })
+  .catch(error => {
+    console.error('\\nError', error)
+  })