Use global variable for OOTB stream app uri (#44)
* Use global variable for OOTB stream app uri * Change release name
This commit is contained in:
committed by
Soby Chacko
parent
7460d3804a
commit
9a02ecbbbd
@@ -23,8 +23,9 @@ include::{docs_dir}/local-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-kafka-10-maven
|
||||
dataflow:>app import --uri {app-import-kafka-maven}
|
||||
```
|
||||
+
|
||||
|
||||
|
||||
@@ -20,10 +20,12 @@ include::{docs_dir}/local-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-kafka-10-maven
|
||||
dataflow:>app import --uri {app-import-kafka-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Create and deploy the following stream
|
||||
+
|
||||
```
|
||||
|
||||
@@ -20,10 +20,12 @@ include::{docs_dir}/local-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Register the out-of-the-box https://github.com/spring-cloud-stream-app-starters/function/blob/master/spring-cloud-starter-stream-app-function/README.adoc[function-runner] application (_we will use the `1.0.0.BUILD-SNAPSHOT` built by the Spring CI system_)
|
||||
+
|
||||
```
|
||||
|
||||
@@ -11,7 +11,9 @@ Sabby Anandan; David Turanski; Glenn Renfro; Eric Bottard; Mark Pollack; Chris S
|
||||
|
||||
:spring-cloud-stream-docs: http://docs.spring.io/spring-cloud-stream/docs/{scst-core-version}/reference/htmlsingle/index.html
|
||||
:github-code: https://github.com/spring-cloud/spring-cloud-dataflow-samples
|
||||
|
||||
:scdf-release-train-name: Celsius-SR1
|
||||
:app-import-kafka-maven: http://bit.ly/{scdf-release-train-name}-stream-applications-kafka-10-maven
|
||||
:app-import-rabbit-maven: http://bit.ly/{scdf-release-train-name}-stream-applications-rabbit-maven
|
||||
|
||||
ifdef::backend-html5[]
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
NOTE: These samples assume that the Data Flow Server can access a remote Maven repository, `https://repo.spring.io/libs-release` by default. If your Data Flow server is running behind a firewall, or you are using a maven proxy preventing
|
||||
access to public repositories, you will need to install the sample apps in your internal Maven repository and https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#getting-started-maven-configuration[configure]
|
||||
the server accordingly. The sample applications are typically registered using Data Flow's bulk import facility. For example, the Shell command `dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven` (The actual URI is release and binder specific so refer to the sample instructions for the actual URL).
|
||||
the server accordingly. The sample applications are typically registered using Data Flow's bulk import facility. For example, the Shell command `dataflow:>app import --uri {app-import-rabbit-maven}` _(The actual URI is release and binder specific so refer to the sample instructions for the actual URL)_.
|
||||
The bulk import URI references a plain text file containing entries for all of the publicly available Spring Cloud Stream and Task applications published to `https://repo.spring.io`. For example,
|
||||
`source.http=maven://org.springframework.cloud.stream.app:http-source-rabbit:1.2.0.RELEASE` registers the `http` source app at the corresponding Maven address, relative to the remote repository(ies) configured for the
|
||||
Data Flow server. The format is `maven://<groupId>:<artifactId>:<version>` You will need to https://repo.spring.io/libs-release/org/springframework/cloud/stream/app/spring-cloud-stream-app-descriptor/Bacon.RELEASE/spring-cloud-stream-app-descriptor-Bacon.RELEASE.rabbit-apps-maven-repo-url.properties[download] the required apps or https://github.com/spring-cloud-stream-app-starters[build] them and then install them in your Maven repository, using whatever group, artifact, and version you choose. If you do
|
||||
|
||||
@@ -29,10 +29,12 @@ CREATE TABLE book (
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-kafka-10-maven
|
||||
dataflow:>app import --uri {app-import-kafka-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
```
|
||||
|
||||
@@ -27,10 +27,12 @@ include::{docs_dir}/cloudfoundry-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
|
||||
|
||||
@@ -88,10 +88,12 @@ Once we verify that the app is started and running without any errors, we can st
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Register the custom processor
|
||||
+
|
||||
```
|
||||
|
||||
@@ -26,9 +26,11 @@ gfsh>create region --name Orders --type=REPLICATE
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
This example creates an gemfire-cq source to which will publish events matching a query criteria on a region. In this case we will monitor the `Orders` region. For simplicity, we will avoid creating a data structure for the order.
|
||||
|
||||
@@ -18,10 +18,12 @@ include::{docs_dir}/cloudfoundry-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Get the PCC connection information
|
||||
+
|
||||
```
|
||||
|
||||
@@ -27,9 +27,11 @@ gfsh>create region --name Test --type=REPLICATE
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
This example creates an gemfire source to which will publish events on a region
|
||||
|
||||
@@ -17,10 +17,12 @@ include::{docs_dir}/cloudfoundry-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Get the PCC connection information
|
||||
+
|
||||
```
|
||||
|
||||
@@ -27,9 +27,11 @@ gfsh>create region --name Stocks --type=REPLICATE
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
This example creates an http endpoint to which we will post stock prices as a JSON document containing `symbol` and `price` fields.
|
||||
|
||||
@@ -17,10 +17,12 @@ include::{docs_dir}/cloudfoundry-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Get the PCC connection information
|
||||
+
|
||||
```
|
||||
|
||||
@@ -25,10 +25,12 @@ CREATE TABLE names
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-kafka-10-maven
|
||||
dataflow:>app import --uri {app-import-kafka-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
```
|
||||
|
||||
@@ -26,10 +26,12 @@ include::{docs_dir}/cloudfoundry-server.adoc[]
|
||||
+
|
||||
include::{docs_dir}/maven-access.adoc[]
|
||||
+
|
||||
[source, bash, subs="attributes"]
|
||||
```
|
||||
dataflow:>app import --uri http://bit.ly/Bacon-RELEASE-stream-applications-rabbit-maven
|
||||
dataflow:>app import --uri {app-import-rabbit-maven}
|
||||
```
|
||||
+
|
||||
+
|
||||
. Create the stream
|
||||
+
|
||||
|
||||
|
||||
Reference in New Issue
Block a user