docs: node wizzard async

influxdata · Oct 18, 2022 · a490282 · a490282
1 parent 8e08f50
commit a490282
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 22 deletions.
diff --git a/src/homepageExperience/components/steps/nodejs/ExecuteAggregateQuery.tsx b/src/homepageExperience/components/steps/nodejs/ExecuteAggregateQuery.tsx
@@ -29,18 +29,16 @@ fluxQuery = \`from(bucket: "${bucket}")
  |> filter(fn: (r) => r._measurement == "measurement1")
  |> mean()\`
 
-queryClient.queryRows(fluxQuery, {
-  next: (row, tableMeta) => {
-    const tableObject = tableMeta.toObject(row)
+try {
+  for await (const {values, tableMeta} of queryClient.iterateRows(fluxQuery)) {
+    const tableObject = tableMeta.toObject(values)
     console.log(tableObject)
-  },
-  error: (error) => {
-    console.error('\\nError', error)
-  },
-  complete: () => {
-    console.log('\\nSuccess')
-  },
-})`
+  }
+
+  console.log('\\nSuccess')
+} catch (error) {
+  console.error('\\nError', error)
+}`
 
   return (
     <>

diff --git a/src/homepageExperience/components/steps/nodejs/ExecuteQuery.tsx b/src/homepageExperience/components/steps/nodejs/ExecuteQuery.tsx
@@ -22,18 +22,16 @@ 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)
+try {
+  for await (const {values, tableMeta} of queryClient.iterateRows(fluxQuery)) {
+    const tableObject = tableMeta.toObject(values)
     console.log(tableObject)
-  },
-  error: (error) => {
-    console.error('\\nError', error)
-  },
-  complete: () => {
-    console.log('\\nSuccess')
-  },
-})`
+  }
+
+  console.log('\\nSuccess')
+} catch (error) {
+  console.error('\\nError', error)
+}`
 
   return (
     <>