Push to HTTP Server

# Import modules from the Python standard library.
import time  # Used to get the current time.
import gzip  # Used to handle data compressed with gzip.


# Import HTTPServer and BaseHTTPRequestHandler classes from the http.server module.
from http.server import HTTPServer, BaseHTTPRequestHandler
import json  # Used to handle JSON data.


# Define a class inheriting from BaseHTTPRequestHandler, used to handle HTTP requests.
class Resquest(BaseHTTPRequestHandler):
    # Override the do_POST method, which is called when the server receives a POST request.
    def do_POST(self):
        # Print the request header information.
        print(str(self.headers))
        # Print the HTTP request command (e.g., POST).
        print(self.command)
        # Read the request body content. The reading length is determined according to the Content-Length field in the request header.
        req_datas = self.rfile.read(int(self.headers['content-length']))
        try:
            # Attempt to decode the request body content and print it.
            print(req_datas.decode())
        except Exception as e:
            # If an exception occurs during decoding, print the exception information.
            print(e)
            # Check whether the request header contains Content-Encoding: gzip. If yes, decompress the request body.
            if self.headers['Content-Encoding'] == 'gzip':
                data = gzip.decompress(req_datas)
                # Print the decompressed gzip content
                print('---------------decompress gzip content-------------------------')
                print(data.decode())
        # Check whether the request path is '/edgeone-logs'. If not, return a 404 error.
        if self.path != '/edgeone-logs':
            self.send_error(404, "Page not Found!")
            return
        # If the request path is correct, prepare the response data.
        data = {
            'result_code': '1',
            'result_desc': 'Success',
            'timestamp': int(time.time())  # Respond with the current timestamp
        }
        # Send an HTTP response status code 200, indicating the request succeeded.
        self.send_response(200)
        # Set the response header Content-type to application/json.
        self.send_header('Content-type', 'application/json')
        # End the sending of response headers.
        self.end_headers()
        # Write the response data in JSON format to the response body.
        self.wfile.write(json.dumps(data).encode('utf-8'))


# Check whether the current script is running as the main program.
if __name__ == '__main__':
    # Define the server listening address and port. You can replace 9002 with your own port.
    host = ('', 9002)
    # Create an HTTPServer object, passing in the listening address and port, and the request handler class.
    server = HTTPServer(host, Resquest)
    # Print the server startup information.
    print("Starting server, listen at: %s:%s" % host)
    # Start the server and keep it running until externally interrupted.
    server.serve_forever()