问答（socketio）
## 监听事件（request）
名称：`QA_CS`
字段：
|名称|类型|说明|
|-|-|-|
|text|str|输入问题|
|room|str|聊天室id，可为空|
示例：
```json
{
"text": "身份证丢了应该怎么办？",
}
```
```json
{
"text": "身份证丢了应该怎么办？",
"room": "12345",
"dialogue": "67890",
"upload_id": ""
}
```
## 发送文本事件（response）
名称：`QA_SS`
字段：
<table>
<tr>
<td>名称</td>
<td>类型</td>
<td>名称</td>
</tr>
<tr>
<td rowspan="4">data</td>
<td>finish_reason</td>
<td>发送状态</td>
</tr>
<tr>
<td>delta</td>
<td>输出内容</td>
</tr>
<tr>
<td>room</td>
<td>聊天室id</td>
</tr>
<tr>
<td>received</td>
<td>其他包装字段</td>
</tr>
</table>
示例：
```json
{
'data': {
'room': 'Ie74LIFDQkyQoiD-AAAX',
'received': {
'text': '身份证丢了怎么办',
'prompt': '材料：特种设备',
'sid': 'Ie74LIFDQkyQoiD-AAAX',
'room': 'Ie74LIFDQkyQoiD-AAAX',
'dialogue': 'Ie74LIFDQkyQoiD-AAAX',
'upload_id': '',
'clue': None,
'alter': None,
'history': [
['你好', '您好，欢迎您直接问我业务问题。']
]
},
'delta': '身份证丢了，可以按照以下步骤进行：<br><br>1.立即向当地公安机关报案，说明身份证丢失的情况，并提交相关证明或文件，例如遗失声明或身份证明等。<br><br>2.如果还需要使用身份证，可以向当地公安机关申请补发或换发。<br><br>3.如果需要旅行或出国，可以向有关机构申请护照或其他身份证明。<br><br>4.在以上步骤中，需要提供一些证明或文件以方便公安机关进行处理。<br><br>请注意，以上步骤可能因地区而异，因此，请根据当地的规定进行操作。',
'finish_reason': 'stop'
}
}
```
## 示例请求代码
```bash
python3 pocketqa.socketio.test.py 123.125.240.150 51074 身份证丢了 QA_CS
```
输出截图
示例代码
```python
# -*- coding: utf-8 -*-
import json
# import threading
import socketio
# 创建Socket.IO客户端实例
sio = socketio.AsyncClient()
# 定义一个用于异步发送消息的函数
async def send_message(message, event_name):
await sio.emit(event_name, message)
# # 在新线程中发送消息
# t = threading.Thread(target=sio.emit, args=('message', message))
# t.start()
# 处理 "message" 事件
@sio.on('CHAT_SS')
async def receive_message(response):
print('Received response: ', response)
@sio.on('SUM_SS')
async def receive_message(response):
print('Received response: ', response)
@sio.on('QA_SS')
async def receive_message(response):
print('Received response: ', response)
@sio.on('GEN_SS')
async def receive_message(response):
print('Received response: ', response)
# 连接到服务器
async def start_server(ip, port, text):
await sio.connect(f'http://{ip}:{port}/', wait=30)
# 发送消息
param = {"text":text, 'sid':'1234567', 'upload_id':''}
await send_message(json.dumps(param))
await sio.wait()
if __name__ == '__main__':
ip = '0.0.0.0'
port = '6006'
text = '增城市的养老院有哪些'
event = 'CHAT_CS'
import sys
if len(sys.argv) > 1:
ip = sys.argv[1]
if len(sys.argv) > 2:
port = sys.argv[2]
if len(sys.argv) > 3:
text = sys.argv[3]
if len(sys.argv) > 4:
event = sys.argv[4]
import asyncio
loop = asyncio.get_event_loop()
loop.run_until_complete(start_server(ip, port, text, event))
```