Python script for logging POST requests to disk

post_sink.py

from http.server import BaseHTTPRequestHandler
import socketserver
import time

PORT = 9000


class SinkHandler(BaseHTTPRequestHandler):
    def do_POST(self):
        incoming = self.rfile

        content_length = int(self.headers['content-length'])
        content = incoming.read(content_length)

        timestamp = time.time_ns()
        output_filename = f"{timestamp}.json"

        output_file = open(output_filename, "wb")
        output_file.write(content)
        output_file.close()

        self.send_response(200, "rcvd")
        self.end_headers()


def run_collector():
    with socketserver.TCPServer(("", PORT), SinkHandler) as httpd:
        print("serving at port", PORT)
        httpd.serve_forever()


if __name__ == '__main__':
    run_collector()