From c3159a1d8b24c8229879d5bba90803c80d024de7 Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 11:16:10 -0400 Subject: [PATCH 1/7] docs: update references to 'Streaming' in UI instructions to 'Streaming tenants' --- modules/pulsar-io/pages/connectors/index.adoc | 4 ++-- .../pulsar-io/partials/connectors/sinks/curl-tab-prereq.adoc | 2 +- .../partials/connectors/sources/curl-tab-prereq.adoc | 2 +- modules/pulsar-io/partials/connectors/sources/monitoring.adoc | 4 ++-- .../real-time-data-pipeline/01-create-astra-objects.adoc | 2 +- 5 files changed, 7 insertions(+), 7 deletions(-) diff --git a/modules/pulsar-io/pages/connectors/index.adoc b/modules/pulsar-io/pages/connectors/index.adoc index 3b08dfc..16434ff 100644 --- a/modules/pulsar-io/pages/connectors/index.adoc +++ b/modules/pulsar-io/pages/connectors/index.adoc @@ -260,7 +260,7 @@ curl:: You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. @@ -310,7 +310,7 @@ curl:: You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. diff --git a/modules/pulsar-io/partials/connectors/sinks/curl-tab-prereq.adoc b/modules/pulsar-io/partials/connectors/sinks/curl-tab-prereq.adoc index 6a95ce2..4fa7afb 100644 --- a/modules/pulsar-io/partials/connectors/sinks/curl-tab-prereq.adoc +++ b/modules/pulsar-io/partials/connectors/sinks/curl-tab-prereq.adoc @@ -1,7 +1,7 @@ You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. diff --git a/modules/pulsar-io/partials/connectors/sources/curl-tab-prereq.adoc b/modules/pulsar-io/partials/connectors/sources/curl-tab-prereq.adoc index 66e59b5..b0a26a2 100644 --- a/modules/pulsar-io/partials/connectors/sources/curl-tab-prereq.adoc +++ b/modules/pulsar-io/partials/connectors/sources/curl-tab-prereq.adoc @@ -1,7 +1,7 @@ You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. diff --git a/modules/pulsar-io/partials/connectors/sources/monitoring.adoc b/modules/pulsar-io/partials/connectors/sources/monitoring.adoc index c9e4d67..458f453 100644 --- a/modules/pulsar-io/partials/connectors/sources/monitoring.adoc +++ b/modules/pulsar-io/partials/connectors/sources/monitoring.adoc @@ -23,7 +23,7 @@ curl:: You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. @@ -85,7 +85,7 @@ curl:: You need a {pulsar-short} token for REST API authentication. This is different from your {astra-db} application tokens. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your tenant's name, and then click the *Settings* tab. diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc index 8e45ce3..41f4043 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc @@ -139,7 +139,7 @@ CREATE TABLE click_data.product_clicks ( == Connecting the topics to the store -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *Streaming*. +. In the {astra-ui-link}, click *Streaming tenants*. . Click your `webstore-clicks` streaming tenant. From 7cfbeb2794e915df75ba7cb1b89966cb0b3845db Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 11:28:59 -0400 Subject: [PATCH 2/7] astra-and-streaming-flow --- .../real-time-data-pipeline/01-create-astra-objects.adoc | 4 ++-- .../real-time-data-pipeline/02-create-decodable-objects.adoc | 2 +- .../real-time-data-pipeline/04-debugging-and-clean-up.adoc | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc index 41f4043..0f966b8 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc @@ -8,7 +8,7 @@ This guide is part of a series that creates a real-time data pipeline with {prod == Creating message topics to capture the stream of click data -. In the {astra-ui-link} header, click icon:grip[name="Applications"], select *Streaming*, and then click **Create Tenant**. +. In the {astra-ui-link}, click *Create tenant*. . Name the new streaming tenant `webstore-clicks`, select any cloud provider and region, and then click **Create Tenant**. @@ -27,7 +27,7 @@ You now have a `production` namespace with two topics, as well as the `default` == Storing the stream of click data -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select *{product-short}*. +. In the {astra-ui-link} header, click **Serverless databases**. . Click **Create database**, and then complete the fields as follows: + diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/02-create-decodable-objects.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/02-create-decodable-objects.adoc index 364c778..3c66110 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/02-create-decodable-objects.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/02-create-decodable-objects.adoc @@ -10,7 +10,7 @@ This guide is part of a series that creates a real-time data pipeline with {prod To connect {product} to Decodable, you need some information from your {product} tenant. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], select **Streaming**, and then click your `webstore-clicks` streaming tenant. +. In the {astra-ui-link}, click *Streaming tenants*, and then click your `webstore-clicks` streaming tenant. + image:decodable-data-pipeline/02/image4.png[] diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc index 3d67935..99fa351 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc @@ -42,13 +42,13 @@ image:decodable-data-pipeline/04/image2.png["Delete decodable connection"] === Removing {product-short} objects -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select **Streaming**. +. In the {astra-ui-link}, click *Streaming tenants*. . Find the `webstore-clicks` tenant, click icon:ellipsis-vertical[name="More"], and then select **Delete**. + This removes the tenant and all associated sinks, topics, messages, and namespaces. -. In the {astra-ui-link} header, click icon:grip[name="Applications"], and then select **{product-short}**. +. In the {astra-ui-link} header, click **Serverless databases**. . Find the `webstore-clicks` database, click icon:ellipsis-vertical[name="More"], and then select **Terminate**. + From 4c8f4270818f345eeaa53f96b4b5ecb81f05fb5f Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 11:34:13 -0400 Subject: [PATCH 3/7] link-cleanup --- modules/functions/pages/index.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/functions/pages/index.adoc b/modules/functions/pages/index.adoc index 1f1d922..8a6c952 100644 --- a/modules/functions/pages/index.adoc +++ b/modules/functions/pages/index.adoc @@ -3,8 +3,8 @@ A {pulsar-short} *transform function* is a low-code implementation of xref:astra-streaming:developing:astream-functions.adoc[{pulsar-short} functions]. + Functions receive data from one or more input topics, apply user-supplied processing, and publish the results to another topic. + -Custom functions are a powerful feature, but for common data transformations, we now include *Transform Functions*. + -<>, <>, <>, and more without coding or deep schema knowledge. + +Custom functions are a powerful feature, but for common data transformations, we now include *Transform Functions*. +Drop fields, flatten, compute, and more without coding or deep schema knowledge. {company} has created the following transform functions for common data transforms, but we're always experimenting with new ones. Check back as the list grows, or let us know some functions you'd find helpful in your deployment. From 49add662b27ddce3098258a346e23cf6b1800073 Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 16:03:26 -0400 Subject: [PATCH 4/7] Apply suggestions from code review Co-authored-by: April I. Murphy <36110273+aimurphy@users.noreply.github.com> --- .../pages/real-time-data-pipeline/01-create-astra-objects.adoc | 2 +- .../real-time-data-pipeline/04-debugging-and-clean-up.adoc | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc index 0f966b8..5fb413a 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc @@ -27,7 +27,7 @@ You now have a `production` namespace with two topics, as well as the `default` == Storing the stream of click data -. In the {astra-ui-link} header, click **Serverless databases**. +. From your tenant's page, click **Dashboard**, and then click **Serverless databases**. . Click **Create database**, and then complete the fields as follows: + diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc index 99fa351..3570c46 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/04-debugging-and-clean-up.adoc @@ -48,7 +48,7 @@ image:decodable-data-pipeline/04/image2.png["Delete decodable connection"] + This removes the tenant and all associated sinks, topics, messages, and namespaces. -. In the {astra-ui-link} header, click **Serverless databases**. +. Click **Serverless databases** to switch to the Serverless databases dashboard. . Find the `webstore-clicks` database, click icon:ellipsis-vertical[name="More"], and then select **Terminate**. + From 64eaaf14108bb308f2c490657f46b78b6f3427b7 Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 16:12:47 -0400 Subject: [PATCH 5/7] Apply suggestions from code review --- .../pages/real-time-data-pipeline/01-create-astra-objects.adoc | 1 + 1 file changed, 1 insertion(+) diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc index 5fb413a..c117119 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/01-create-astra-objects.adoc @@ -139,6 +139,7 @@ CREATE TABLE click_data.product_clicks ( == Connecting the topics to the store +. To return to the *Streaming tenants* dashboard from the CQL console, click your user name, and then select the org your `webstore-clicks` streaming tenant was created in. . In the {astra-ui-link}, click *Streaming tenants*. . Click your `webstore-clicks` streaming tenant. From 301e269bbb2d521a0acbd2cae00ec791a2754e80 Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 16:18:31 -0400 Subject: [PATCH 6/7] replace-navigation-to-streaming --- .../real-time-data-pipeline/03-put-it-all-together.adoc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc index 8d3c275..1eff2ce 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc @@ -74,13 +74,13 @@ In “Input Metrics”, we see that 1 record has been received. + image:decodable-data-pipeline/03/image4.png[] -. Return to your {product} tenant “webstore-clicks” and navigate to the “Namespace and Topics” area. +. Return to your “webstore-clicks” tenant and navigate to the “Namespace and Topics” area. Expand the “production” namespace and select the “all-clicks” topic. Confirm that “Data In” has 1 message and “Data Out” has 1 message. This means the topic took the data in and a consumer acknowledged receipt of the message. + image:decodable-data-pipeline/03/image6.png[] -. In the “Sinks” tab in {product}, select the “all-clicks” sink. In “Instance Stats” you see “Reads” has a value of 1 and “Writes” has a value of 1. This means the sink consumed a message from the topic and wrote the data to the store. +. In the “Sinks” tab, select the “all-clicks” sink. In “Instance Stats” you see “Reads” has a value of 1 and “Writes” has a value of 1. This means the sink consumed a message from the topic and wrote the data to the store. + image:decodable-data-pipeline/03/image5.png[] @@ -128,7 +128,7 @@ Similar to how you followed the above flow of raw click data, follow this flow t . Go to your `Astra-Streaming-Product-Webclicks-Connection` connection, and then check that the **Input Metrics** have 1 record. -. In {product}, go to your tenant, and then go to the `product-clicks` topic in the `production` namespace. +Go to your `webstore-clicks` tenant, and then go to the `product-clicks` topic in the `production` namespace. . Make sure **Data In** and **Data Out** have 1 message each. From 9fdcfe22150a309a16ddae32163b36426356f77d Mon Sep 17 00:00:00 2001 From: Mendon Kissling <59585235+mendonk@users.noreply.github.com> Date: Fri, 29 Aug 2025 16:32:18 -0400 Subject: [PATCH 7/7] remove-delimiter-blocks-causing-errors --- .../pages/real-time-data-pipeline/03-put-it-all-together.adoc | 2 -- 1 file changed, 2 deletions(-) diff --git a/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc b/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc index 1eff2ce..af86d5a 100644 --- a/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc +++ b/modules/use-cases-architectures/pages/real-time-data-pipeline/03-put-it-all-together.adoc @@ -88,7 +88,6 @@ image:decodable-data-pipeline/03/image5.png[] + In the {astra-ui}, go to your `webstore-clicks` database, click **CQL Console**, and then run the following CQL statement: + --- [source,sql,subs="attributes+"] ---- select * from click_data.all_clicks; @@ -134,7 +133,6 @@ Go to your `webstore-clicks` tenant, and then go to the `product-clicks` topic i . In the {astra-ui}, go to your `webstore-clicks` database, click **CQL Console**, and then query the `product_clicks` table to inspect the data in the database: + --- [source,sql,subs="attributes+"] ---- select * from click_data.product_clicks;