Create my_tcp_server.py
Browse files- my_tcp_server.py +27 -0
my_tcp_server.py
ADDED
|
@@ -0,0 +1,27 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
import os
|
| 2 |
+
import socket
|
| 3 |
+
|
| 4 |
+
# get hf space repo id in format "user/space"
|
| 5 |
+
repo_id = os.getenv("REPO_ID", "")
|
| 6 |
+
user, space = repo_id.split("/")
|
| 7 |
+
port = int(os.getenv("PORT", "5678"))
|
| 8 |
+
host = f"{space}.{user}.hf.space"
|
| 9 |
+
|
| 10 |
+
# print the tcp url
|
| 11 |
+
print(f"tcp://{host}:{port}")
|
| 12 |
+
|
| 13 |
+
# setup tcp server
|
| 14 |
+
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| 15 |
+
sock.bind(("0.0.0.0", port))
|
| 16 |
+
sock.listen()
|
| 17 |
+
|
| 18 |
+
print(f"listening on 0.0.0.0:{port}")
|
| 19 |
+
while True:
|
| 20 |
+
conn, addr = sock.accept()
|
| 21 |
+
print("connection from", addr)
|
| 22 |
+
data = conn.recv(1024)
|
| 23 |
+
if not data:
|
| 24 |
+
conn.close()
|
| 25 |
+
continue
|
| 26 |
+
conn.sendall(data)
|
| 27 |
+
conn.close()
|