Merge branch 'v1.14' into maintainer-comment-actions

Author: WhitWaldo

daprdocs/content/en/developing-applications/building-blocks/pubsub/pubsub-bulk.md

@@ -336,14 +336,13 @@ Status | Description
 `RETRY` | Message to be retried by Dapr
 `DROP` | Warning is logged and message is dropped
 
-Please refer [Expected HTTP Response for Bulk Subscribe]({{< ref pubsub_api.md >}}) for further insights on response.
+Refer to [Expected HTTP Response for Bulk Subscribe]({{< ref pubsub_api.md >}}) for further insights on response.
 
 ### Example
 
-Please refer following code samples for how to use Bulk Subscribe:
-
-{{< tabs "Java" "JavaScript" ".NET" >}}
+The following code examples demonstrate how to use Bulk Subscribe.
 
+{{< tabs "Java" "JavaScript" ".NET" "Python" >}}
 {{% codetab %}}
 
 ```java
@@ -471,7 +470,50 @@ public class BulkMessageController : ControllerBase
 
 {{% /codetab %}}
 
+{{% codetab %}}
+Currently, you can only bulk subscribe in Python using an HTTP client. 
+
+```python
+import json
+from flask import Flask, request, jsonify
+
+app = Flask(__name__)
+
+@app.route('/dapr/subscribe', methods=['GET'])
+def subscribe():
+    # Define the bulk subscribe configuration
+    subscriptions = [{
+        "pubsubname": "pubsub",
+        "topic": "TOPIC_A",
+        "route": "/checkout",
+        "bulkSubscribe": {
+            "enabled": True,
+            "maxMessagesCount": 3,
+            "maxAwaitDurationMs": 40
+        }
+    }]
+    print('Dapr pub/sub is subscribed to: ' + json.dumps(subscriptions))
+    return jsonify(subscriptions)
+
+
+# Define the endpoint to handle incoming messages
+@app.route('/checkout', methods=['POST'])
+def checkout():
+    messages = request.json
+    print(messages)
+    for message in messages:
+        print(f"Received message: {message}")
+    return json.dumps({'success': True}), 200, {'ContentType': 'application/json'}
+
+if __name__ == '__main__':
+    app.run(port=5000)
+
+```
+
+{{% /codetab %}}
+
 {{< /tabs >}}
+
 ## How components handle publishing and subscribing to bulk messages
 
 For event publish/subscribe, two kinds of network transfers are involved.

daprdocs/content/en/developing-applications/building-blocks/pubsub/subscription-methods.md

@@ -203,47 +203,7 @@ As messages are sent to the given message handler code, there is no concept of r
 
 The example below shows the different ways to stream subscribe to a topic.
 
-{{< tabs ".NET" Go>}}
-
-{{% codetab %}}
-
-```csharp
-using Dapr.Messaging.PublishSubscribe;
-
-var clientBuilder = new DaprPublishSubscribeClientBuilder();
-var daprMessagingClient = clientBuilder.Build();
-
-async Task<TopicResponseAction> HandleMessage(TopicMessage message, CancellationToken cancellationToken = default)
-{
-    try
-    {
-        //Do something with the message
-		Console.WriteLine(Encoding.UTF8.GetString(message.Data.Span));
-
-        return await Task.FromResult(TopicResponseAction.Success);
-    }
-    catch
-    {
-        return await Task.FromResult(TopicResponseAction.Retry);
-    }
-}
-
-//Create a dynamic streaming subscription
-var subscription = daprMessagingClient.Register("pubsub", "myTopic",
-    new DaprSubscriptionOptions(new MessageHandlingPolicy(TimeSpan.FromSeconds(15), TopicResponseAction.Retry)),
-    HandleMessage, CancellationToken.None);
-
-//Subscribe to messages on it with a timeout of 30 seconds
-var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(30));
-await subscription.SubscribeAsync(cancellationTokenSource.Token);
-
-await Task.Delay(TimeSpan.FromMinutes(1));
-
-//When you're done with the subscription, simply dispose of it
-await subscription.DisposeAsync();
-```
-
-{{% /codetab %}}
+{{< tabs Go>}}
 
 {{% codetab %}}
 

daprdocs/content/en/operations/observability/_index.md

@@ -6,7 +6,7 @@ weight: 60
 description: See and measure the message calls to components and between networked services
 ---
 
-[The following overview video and demo](https://www.youtube.com/live/0y7ne6teHT4?si=3bmNSSyIEIVSF-Ej&t=9931) demonstrates how observability in Dapr works. 
+[The following overview video and demo](https://www.youtube.com/watch?v=0y7ne6teHT4&t=12652s) demonstrates how observability in Dapr works. 
 
 <iframe width="560" height="315" src="https://www.youtube.com/embed/0y7ne6teHT4?si=iURnLk57t2zN-7zP&amp;start=12653" title="YouTube video player" style="padding-bottom:25px;" frameborder="0" allow="accelerometer; autoplay; clipboard-write; encrypted-media; gyroscope; picture-in-picture; web-share" allowfullscreen></iframe>