Update 07-tmq.mdx
This commit is contained in:
parent
a89f945e4f
commit
51fdbe430e
|
@ -90,6 +90,7 @@ void close() throws SQLException;
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem value="Python" label="Python">
|
<TabItem value="Python" label="Python">
|
||||||
|
|
||||||
```python
|
```python
|
||||||
class TaosConsumer():
|
class TaosConsumer():
|
||||||
def __init__(self, *topics, **configs)
|
def __init__(self, *topics, **configs)
|
||||||
|
@ -107,9 +108,10 @@ class TaosConsumer():
|
||||||
def close(self)
|
def close(self)
|
||||||
|
|
||||||
def __del__(self)
|
def __del__(self)
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
<TabItem label="Go" value="Go">
|
<TabItem label="Go" value="Go">
|
||||||
|
|
||||||
```go
|
```go
|
||||||
|
@ -152,7 +154,6 @@ void Unsubscribe()
|
||||||
void Commit(ConsumeResult consumerResult)
|
void Commit(ConsumeResult consumerResult)
|
||||||
|
|
||||||
void Close()
|
void Close()
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
@ -590,6 +591,7 @@ consumer.Unsubscribe();
|
||||||
|
|
||||||
// 关闭消费
|
// 关闭消费
|
||||||
consumer.Close();
|
consumer.Close();
|
||||||
|
```
|
||||||
</TabItem>
|
</TabItem>
|
||||||
|
|
||||||
</Tabs>
|
</Tabs>
|
||||||
|
|
Loading…
Reference in New Issue