docs: fix python tmq demo

This commit is contained in:
Adam Ji 2024-02-29 10:42:12 +08:00
parent 7f7b61af5c
commit d4900d0633
2 changed files with 4 additions and 8 deletions

View File

@ -902,16 +902,14 @@ while True:
</TabItem>
<TabItem value="websocket" label="WebSocket connection">
The `poll` function is used to consume data in tmq. The parameter of the `poll` function is a value of type float representing the timeout in seconds. It returns a `Message` before timing out, or `None` on timing out. You have to handle error messages in response data.
The `poll` function is used to consume data in tmq. The parameter of the `poll` function is a value of type float representing the timeout in seconds. It returns a `Message` before timing out, or `None` on timing out.
```python
while True:
message = consumer.poll(1)
if not message:
continue
err = message.error()
if err is not None:
raise err
for block in message:
for row in block:
print(row)

View File

@ -911,16 +911,14 @@ while True:
</TabItem>
<TabItem value="websocket" label="WebSocket 连接">
Consumer API 的 `poll` 方法用于消费数据,`poll` 方法接收一个 float 类型的超时时间超时时间单位为秒s`poll` 方法在超时之前返回一条 Message 类型的数据或超时返回 `None`。消费者必须通过 Message 的 `error()` 方法校验返回数据的 error 信息。
Consumer API 的 `poll` 方法用于消费数据,`poll` 方法接收一个 float 类型的超时时间超时时间单位为秒s`poll` 方法在超时之前返回一条 Message 类型的数据或超时返回 `None`。
```python
while True:
message = consumer.poll(1)
if not message:
continue
err = message.error()
if err is not None:
raise err
for block in message:
for row in block:
print(row)