dapr
/
docs
mirror of https://github.com/dapr/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix pubsub quickstart component name to match QS source code 

Signed-off-by: Nick Greenfield <nigreenf@microsoft.com>
This commit is contained in:
Nick Greenfield 2022-08-10 13:51:42 -07:00
parent d123afa1c5
commit 036d5c4390
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
daprdocs/content/en/getting-started/quickstarts/pubsub-quickstart.md
View File

@ -61,14 +61,14 @@ dapr run --app-id order-processor --components-path ../../../components/ --app-p
> **Note**: Since Python3.exe is not defined in Windows, you may need to use `python app.py` instead of `python3 app.py`. > **Note**: Since Python3.exe is not defined in Windows, you may need to use `python app.py` instead of `python3 app.py`.
In the `order-processor` subscriber, we're subscribing to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar. In the `order-processor` subscriber, we're subscribing to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar.
```py ```py
# Register Dapr pub/sub subscriptions # Register Dapr pub/sub subscriptions
@app.route('/dapr/subscribe', methods=['GET']) @app.route('/dapr/subscribe', methods=['GET'])
def subscribe(): def subscribe():
subscriptions = [{ subscriptions = [{
'pubsubname': 'order_pub_sub', 'pubsubname': 'orderpubsub',
'topic': 'orders', 'topic': 'orders',
'route': 'orders' 'route': 'orders'
}] }]
@ -110,13 +110,13 @@ dapr run --app-id checkout --components-path ../../../components/ -- python3 app
> **Note**: Since Python3.exe is not defined in Windows, you may need to use `python app.py` instead of `python3 app.py`. > **Note**: Since Python3.exe is not defined in Windows, you may need to use `python app.py` instead of `python3 app.py`.
In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop: In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop:
```python ```python
with DaprClient() as client: with DaprClient() as client:
# Publish an event/message using Dapr PubSub # Publish an event/message using Dapr PubSub
result = client.publish_event( result = client.publish_event(
pubsub_name='order_pub_sub', pubsub_name='orderpubsub',
topic_name='orders', topic_name='orders',
data=json.dumps(order), data=json.dumps(order),
data_content_type='application/json', data_content_type='application/json',
@ -172,7 +172,7 @@ The Redis `pubsub.yaml` file included for this Quickstart contains the following
apiVersion: dapr.io/v1alpha1 apiVersion: dapr.io/v1alpha1
kind: Component kind: Component
metadata: metadata:
name: order_pub_sub name: orderpubsub
spec: spec:
type: pubsub.redis type: pubsub.redis
version: v1 version: v1
@ -238,10 +238,10 @@ Run the `order-processor` subscriber service alongside a Dapr sidecar.
dapr run --app-port 5001 --app-id order-processing --app-protocol http --dapr-http-port 3501 --components-path ../../../components -- npm run start dapr run --app-port 5001 --app-id order-processing --app-protocol http --dapr-http-port 3501 --components-path ../../../components -- npm run start
``` ```
In the `order-processor` subscriber, we're subscribing to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar. In the `order-processor` subscriber, we're subscribing to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar.
```js ```js
server.pubsub.subscribe("order_pub_sub", "orders", (data) => console.log("Subscriber received: " + JSON.stringify(data))); server.pubsub.subscribe("orderpubsub", "orders", (data) => console.log("Subscriber received: " + JSON.stringify(data)));
``` ```
### Step 4: Publish a topic ### Step 4: Publish a topic
@ -270,7 +270,7 @@ Run the `checkout` publisher service alongside a Dapr sidecar.
dapr run --app-id checkout --app-protocol http --dapr-http-port 3500 --components-path ../../../components -- npm run start dapr run --app-id checkout --app-protocol http --dapr-http-port 3500 --components-path ../../../components -- npm run start
``` ```
In the `checkout` publisher service, we're publishing the orderId message to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop: In the `checkout` publisher service, we're publishing the orderId message to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop:
```js ```js
const client = new DaprClient(DAPR_HOST, DAPR_HTTP_PORT); const client = new DaprClient(DAPR_HOST, DAPR_HTTP_PORT);
@ -330,7 +330,7 @@ The Redis `pubsub.yaml` file included for this Quickstart contains the following
apiVersion: dapr.io/v1alpha1 apiVersion: dapr.io/v1alpha1
kind: Component kind: Component
metadata: metadata:
name: order_pub_sub name: orderpubsub
spec: spec:
type: pubsub.redis type: pubsub.redis
version: v1 version: v1
@ -392,11 +392,11 @@ Run the `order-processor` subscriber service alongside a Dapr sidecar.
dapr run --app-id order-processor --components-path ../../../components --app-port 7001 -- dotnet run dapr run --app-id order-processor --components-path ../../../components --app-port 7001 -- dotnet run
``` ```
In the `order-processor` subscriber, we're subscribing to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar. In the `order-processor` subscriber, we're subscribing to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar.
```cs ```cs
// Dapr subscription in [Topic] routes orders topic to this route // Dapr subscription in [Topic] routes orders topic to this route
app.MapPost("/orders", [Topic("order_pub_sub", "orders")] (Order order) => { app.MapPost("/orders", [Topic("orderpubsub", "orders")] (Order order) => {
Console.WriteLine("Subscriber received : " + order); Console.WriteLine("Subscriber received : " + order);
return Results.Ok(order); return Results.Ok(order);
}); });
@ -426,11 +426,11 @@ Run the `checkout` publisher service alongside a Dapr sidecar.
dapr run --app-id checkout --components-path ../../../components -- dotnet run dapr run --app-id checkout --components-path ../../../components -- dotnet run
``` ```
In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop: In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop:
```cs ```cs
using var client = new DaprClientBuilder().Build(); using var client = new DaprClientBuilder().Build();
await client.PublishEventAsync("order_pub_sub", "orders", order); await client.PublishEventAsync("orderpubsub", "orders", order);
Console.WriteLine("Published data: " + order); Console.WriteLine("Published data: " + order);
``` ```
@ -483,7 +483,7 @@ The Redis `pubsub.yaml` file included for this Quickstart contains the following
apiVersion: dapr.io/v1alpha1 apiVersion: dapr.io/v1alpha1
kind: Component kind: Component
metadata: metadata:
name: order_pub_sub name: orderpubsub
spec: spec:
type: pubsub.redis type: pubsub.redis
version: v1 version: v1
@ -547,10 +547,10 @@ Run the `order-processor` subscriber service alongside a Dapr sidecar.
dapr run --app-port 8080 --app-id order-processor --components-path ../../../components -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar dapr run --app-port 8080 --app-id order-processor --components-path ../../../components -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar
``` ```
In the `order-processor` subscriber, we're subscribing to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar. In the `order-processor` subscriber, we're subscribing to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar.
```java ```java
@Topic(name = "orders", pubsubName = "order_pub_sub") @Topic(name = "orders", pubsubName = "orderpubsub")
@PostMapping(path = "/orders", consumes = MediaType.ALL_VALUE) @PostMapping(path = "/orders", consumes = MediaType.ALL_VALUE)
public Mono<ResponseEntity> getCheckout(@RequestBody(required = false) CloudEvent<Order> cloudEvent) { public Mono<ResponseEntity> getCheckout(@RequestBody(required = false) CloudEvent<Order> cloudEvent) {
return Mono.fromSupplier(() -> { return Mono.fromSupplier(() -> {
@ -585,7 +585,7 @@ Run the `checkout` publisher service alongside a Dapr sidecar.
dapr run --app-id checkout --components-path ../../../components -- java -jar target/CheckoutService-0.0.1-SNAPSHOT.jar dapr run --app-id checkout --components-path ../../../components -- java -jar target/CheckoutService-0.0.1-SNAPSHOT.jar
``` ```
In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop: In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop:
```java ```java
DaprClient client = new DaprClientBuilder().build(); DaprClient client = new DaprClientBuilder().build();
@ -645,7 +645,7 @@ The Redis `pubsub.yaml` file included for this Quickstart contains the following
apiVersion: dapr.io/v1alpha1 apiVersion: dapr.io/v1alpha1
kind: Component kind: Component
metadata: metadata:
name: order_pub_sub name: orderpubsub
spec: spec:
type: pubsub.redis type: pubsub.redis
version: v1 version: v1
@ -709,7 +709,7 @@ Run the `order-processor` subscriber service alongside a Dapr sidecar.
dapr run --app-port 6001 --app-id order-processor --app-protocol http --dapr-http-port 3501 --components-path ../../../components -- go run app.go dapr run --app-port 6001 --app-id order-processor --app-protocol http --dapr-http-port 3501 --components-path ../../../components -- go run app.go
``` ```
In the `order-processor` subscriber, we're subscribing to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar. In the `order-processor` subscriber, we're subscribing to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. This enables your app code to talk to the Redis component instance through the Dapr sidecar.
```go ```go
func eventHandler(ctx context.Context, e *common.TopicEvent) (retry bool, err error) { func eventHandler(ctx context.Context, e *common.TopicEvent) (retry bool, err error) {
@ -739,7 +739,7 @@ Run the `checkout` publisher service alongside a Dapr sidecar.
dapr run --app-id checkout --app-protocol http --dapr-http-port 3500 --components-path ../../../components -- go run app.go dapr run --app-id checkout --app-protocol http --dapr-http-port 3500 --components-path ../../../components -- go run app.go
``` ```
In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `order_pub_sub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop: In the `checkout` publisher, we're publishing the orderId message to the Redis instance called `orderpubsub` [(as defined in the `pubsub.yaml` component)]({{< ref "#pubsubyaml-component-file" >}}) and topic `orders`. As soon as the service starts, it publishes in a loop:
```go ```go
client, err := dapr.NewClient() client, err := dapr.NewClient()
@ -803,7 +803,7 @@ The Redis `pubsub.yaml` file included for this Quickstart contains the following
apiVersion: dapr.io/v1alpha1 apiVersion: dapr.io/v1alpha1
kind: Component kind: Component
metadata: metadata:
name: order_pub_sub name: orderpubsub
spec: spec:
type: pubsub.redis type: pubsub.redis
version: v1 version: v1