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

remove loop 

Signed-off-by: Hannah Hunter <hannahhunter@microsoft.com>
This commit is contained in:
Hannah Hunter 2023-06-30 13:37:57 -04:00
parent aaa2c2a203
commit ff1f2803df
1 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
daprdocs/content/en/developing-applications/building-blocks/pubsub/pubsub-cloudevents.md
View File

@ -101,14 +101,13 @@ For example, to replace the `source` and `id` values from [the CloudEvent exampl
```python ```python
with DaprClient() as client: with DaprClient() as client:
for i in range(1): order = {'orderId': i}
order = {'orderId': i} # 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='order_pub_sub', topic_name='orders',
topic_name='orders', publish_metadata={'cloudevent-id: 'd99b228f-6c73-4e78-8c4d-3f80a043d317', cloudevent-source: 'payment'}
publish_metadata={'cloudevent-id: 'd99b228f-6c73-4e78-8c4d-3f80a043d317', cloudevent-source: 'payment'} )
)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -117,22 +116,20 @@ with DaprClient() as client:
{{% codetab %}} {{% codetab %}}
```csharp ```csharp
for (int i = 1) { var order = new Order(i);
var order = new Order(i); using var client = new DaprClientBuilder().Build();
using var client = new DaprClientBuilder().Build();
// Override cloudevent metadata // Override cloudevent metadata
var metadata = new Dictionary<string,string>() { var metadata = new Dictionary<string,string>() {
{ "cloudevent.source", "payment" }, { "cloudevent.source", "payment" },
{ "cloudevent.id", "d99b228f-6c73-4e78-8c4d-3f80a043d317" } { "cloudevent.id", "d99b228f-6c73-4e78-8c4d-3f80a043d317" }
}
// Publish an event/message using Dapr PubSub
await client.PublishEventAsync("order_pub_sub", "orders", order, metadata);
Console.WriteLine("Published data: " + order);
await Task.Delay(TimeSpan.FromSeconds(1));
} }
// Publish an event/message using Dapr PubSub
await client.PublishEventAsync("order_pub_sub", "orders", order, metadata);
Console.WriteLine("Published data: " + order);
await Task.Delay(TimeSpan.FromSeconds(1));
``` ```
{{% /codetab %}} {{% /codetab %}}