Push to HTTP Server

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


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


# Define a class that inherits 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 request header information
        print(str(self.headers))
        # Print the command from the HTTP request (e.g., POST)
        print(self.command)
        # Read the request body content, determining the length to read as specified in the Content-Length field
        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 if the request header contains Content-Encoding: gzip, if so, 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 if 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 was successful
        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 if 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, port, and the request handler class
    server = HTTPServer(host, Resquest)
    # Print server startup information
    print("Starting server, listen at: %s:%s" % host)
    # Start the server and keep it running until externally interrupted
    server.serve_forever()