add python example

This commit is contained in:
menshibin 2024-08-05 14:12:11 +08:00 committed by gccgdb1234
parent 9c0547ef81
commit e3158e2867
1 changed files with 6 additions and 0 deletions

View File

@ -230,6 +230,9 @@ Rust 连接器创建消费者的参数为 DSN 可以设置的参数列表请
```python
{{#include docs/examples/python/tmq_websocket_example.py:subscribe}}
```
- `subscribe` 方法的参数含义为:订阅的主题列表(即名称),支持同时订阅多个主题。
- `poll` 每次调用获取一个消息,一个消息中可能包含多个记录。
- `records` 包含了多个 block 块, 每个块中可能包含多个记录。
</TabItem>
<TabItem label="Go" value="go">
@ -281,6 +284,9 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
```python
{{#include docs/examples/python/tmq_native.py:subscribe}}
```
- `subscribe` 方法的参数含义为:订阅的主题列表(即名称),支持同时订阅多个主题。
- `poll` 每次调用获取一个消息,一个消息中可能包含多个记录。
- `records` 包含了多个 block 块, 每个块中可能包含多个记录。
</TabItem>
<TabItem label="Go" value="go">