生成（socketio）
## 监听事件（request）
名称：`GEN_CS`
字段：
|名称|类型|说明|
|-|-|-|
|text|str|输入问题|
|room|str|聊天室id，可为空|
示例：
```json
{
"text": "身份证丢了应该怎么办？",
}
```
```json
{
"text": "身份证丢了应该怎么办？",
"room": "12345",
"dialogue": "67890",
"upload_id": ""
}
```
## 发送文本事件（response）
名称：`GEN_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': 'zE9w829PW6Sj0kNcAAAZ',
'received': {
'text': '身份证丢了怎么办',
'prompt': '材料：特种设备',
'sid': 'zE9w829PW6Sj0kNcAAAZ',
'room': 'zE9w829PW6Sj0kNcAAAZ',
'dialogue': 'zE9w829PW6Sj0kNcAAAZ',
'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 以校园安全事件为题写一篇通知公文 GEN_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))
```