gp_binance_demo/kappa/rest_server.py

import http.server
import json
import socketserver
import data_processing
from logger_config import logger


class MyRequestHandler(http.server.BaseHTTPRequestHandler):
    def do_GET(self):
        # 构造要返回的 JSON 数据
        response_data = {
            "delta_sum": data_processing.delta_sum,
            "status": True
        }

        # 将数据转换为 JSON 格式
        json_data = json.dumps(response_data)

        # 发送响应头
        self.send_response(200)
        self.send_header("Content-type", "application/json")
        self.end_headers()

        # 发送 JSON 数据
        self.wfile.write(json_data.encode('utf-8'))

    def log_message(self, format, *args):
        pass


PORT = 9999


def start_http_server():
    with socketserver.TCPServer(("", PORT), MyRequestHandler) as httpd:
        logger.info(f"Serving rest at port {PORT}")
        httpd.serve_forever()