对话（socketio）
## 监听事件（request）
名称：`CHAT_CS`
字段：
|名称|类型|说明|
|-|-|-|
|text|str|输入问题|
|room|str|聊天室id，可为空|
|upload_id|str|上传id|
示例：
```json
{
"text": "身份证丢了应该怎么办？",
"upload_id": ""
}
```
```json
{
"text": "身份证丢了应该怎么办？",
"room": "12345",
"dialogue": "67890",
"upload_id": ""
}
```
## 发送事件（response）
名称：`CHAT_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>其他包装字段，包括clue、alter</td>
</tr>
</table>
示例：
```json
{
'data': {
'room': 'dDV49Eg3sxnyjZz4AAAR',
'received': {
'text': '身份证丢了应该怎么办',
'prompt': '材料：特种设备',
'sid': 'dDV49Eg3sxnyjZz4AAAR',
'room': 'dDV49Eg3sxnyjZz4AAAR',
'dialogue': 'dDV49Eg3sxnyjZz4AAAR',
'upload_id': '',
'clue': {
'type': '知识库依据：',
'data': ['材料：特种设备作', '0.9247700572013855', '<small><i>（由语言模型自动生成）</i></small>']
},
'alter': ['特种设备作业人员证丢失了怎么办', '如何办理村民遗失身份证', '我的永居证遗失了，该怎么办'],
'history': [
['你好', '您好，欢迎您直接问我业务问题。']
]
},
'delta': '根据《中华人民共和国身份证法》第二十五条规定：公民丢失身份证，应当向常住户口所在地的派出所申请补发。该派出所应当自公民提交补发申请之日起十日内审核并发放。在办理过程中，该派出所可以查询相关信息、核实身份、办理相关业务等。咨询电话：12388。',
'finish_reason': 'stop'
}
}
```
## 示例请求代码
```bash
python3 pocketqa.socketio.test.py 123.125.240.150 51074 你好 CHAT_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))
```