This commit is contained in:
lwl0608 2024-12-01 22:18:16 +08:00
parent 2a388bea72
commit 025b4e5b33
2 changed files with 30 additions and 2 deletions

View File

@ -1,13 +1,13 @@
from lib.all import *
csv_w = Csv(
"income_11_104684.csv", ["用户id", "昵称", "空间解锁", "主播收入钻石"]
"income_11_983565.csv", ["用户id", "昵称", "空间解锁", "主播收入钻石"]
)
st_str = "2024-11-01 00:00:00"
et_str = "2024-12-01 00:00:00"
uids = [104684]
uids = [983565]
class S:

28
ws/demo.py Normal file
View File

@ -0,0 +1,28 @@
import asyncio
import websockets
async def communicate(uri):
async with websockets.connect(uri) as websocket:
while True:
message_to_send = input("Enter message to send (or 'quit' to exit): ")
if message_to_send.lower() == 'quit':
break
await websocket.send(message_to_send)
print(f"Sent: {message_to_send}")
try:
received_message = await websocket.recv()
print(f"Received: {received_message}")
except websockets.ConnectionClosed:
print("Connection closed by server.")
break
async def main():
await communicate("ws://127.0.0.1:7980/ws?mid=111")
if __name__ == "__main__":
asyncio.run(main())