docs: node wizzard async

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

Hide file tree

Showing 4 changed files with 50 additions and 44 deletions.
diff --git a/src/homepageExperience/components/steps/nodejs/ExecuteAggregateQuery.tsx b/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 (
     <>

diff --git a/src/homepageExperience/components/steps/nodejs/ExecuteQuery.tsx b/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 (
     <>

diff --git a/src/writeData/clients/Javascript/execute.example b/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)
+  })
 
diff --git a/src/writeData/clients/Javascript/executeFull.example b/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)
+  })