@@ -23,7 +23,12 @@ async def publish_cloud_events(
23
23
content_type : str = "application/cloudevents-batch+json; charset=utf-8" ,
24
24
** kwargs : Any
25
25
) -> None :
26
- """Publish Batch of Cloud Events to namespace topic.
26
+ """Publish Batch Cloud Event to namespace topic. In case of success, the server responds with an
27
+ HTTP 200 status code with an empty JSON object in response. Otherwise, the server can return
28
+ various error codes. For example, 401: which indicates authorization failure, 403: which
29
+ indicates quota exceeded or message is too large, 410: which indicates that specific topic is
30
+ not found, 400: for bad request, and 500: for internal server error.
31
+
27
32
:param topic_name: Topic Name. Required.
28
33
:type topic_name: str
29
34
:param body: Array of Cloud Events being published. Required.
@@ -34,7 +39,7 @@ async def publish_cloud_events(
34
39
:keyword bool stream: Whether to stream the response of this operation. Defaults to False. You
35
40
will have to context manage the returned stream.
36
41
:return: None
37
- :rtype: None
42
+ :rtype: None
38
43
:raises ~azure.core.exceptions.HttpResponseError:
39
44
"""
40
45
@@ -47,7 +52,12 @@ async def publish_cloud_events(
47
52
content_type : str = "application/cloudevents+json; charset=utf-8" ,
48
53
** kwargs : Any
49
54
) -> None :
50
- """Publish Single Cloud Event to namespace topic.
55
+ """Publish Single Cloud Event to namespace topic. In case of success, the server responds with an
56
+ HTTP 200 status code with an empty JSON object in response. Otherwise, the server can return
57
+ various error codes. For example, 401: which indicates authorization failure, 403: which
58
+ indicates quota exceeded or message is too large, 410: which indicates that specific topic is
59
+ not found, 400: for bad request, and 500: for internal server error.
60
+
51
61
:param topic_name: Topic Name. Required.
52
62
:type topic_name: str
53
63
:param body: Single Cloud Event being published. Required.
@@ -58,26 +68,31 @@ async def publish_cloud_events(
58
68
:keyword bool stream: Whether to stream the response of this operation. Defaults to False. You
59
69
will have to context manage the returned stream.
60
70
:return: None
61
- :rtype: None
71
+ :rtype: None
62
72
:raises ~azure.core.exceptions.HttpResponseError:
63
73
"""
64
74
65
75
@distributed_trace_async
66
76
async def publish_cloud_events (
67
77
self , topic_name : str , body : Union [List [CloudEvent ], CloudEvent ], ** kwargs
68
78
) -> None :
69
- """Publish Cloud Events to namespace topic.
79
+ """Publish Batch Cloud Event or Events to namespace topic. In case of success, the server responds with an
80
+ HTTP 200 status code with an empty JSON object in response. Otherwise, the server can return
81
+ various error codes. For example, 401: which indicates authorization failure, 403: which
82
+ indicates quota exceeded or message is too large, 410: which indicates that specific topic is
83
+ not found, 400: for bad request, and 500: for internal server error.
84
+
70
85
:param topic_name: Topic Name. Required.
71
86
:type topic_name: str
72
- :param body: Single Cloud Event or list of Cloud Events being published. Required.
87
+ :param body: Cloud Event or Array of Cloud Events being published. Required.
73
88
:type body: ~azure.core.messaging.CloudEvent or list[~azure.core.messaging.CloudEvent]
74
89
:keyword content_type: content type. Default value is "application/cloudevents+json;
75
90
charset=utf-8".
76
91
:paramtype content_type: str
77
92
:keyword bool stream: Whether to stream the response of this operation. Defaults to False. You
78
93
will have to context manage the returned stream.
79
94
:return: None
80
- :rtype: None
95
+ :rtype: None
81
96
:raises ~azure.core.exceptions.HttpResponseError:
82
97
"""
83
98
if isinstance (body , CloudEvent ):
0 commit comments