POST /api HTTP/1.1
Host: 127.0.0.1:1715
Connection: keep-alive
Accept-Encoding: gzip, deflate
Accept: */*
User-Agent: python-requests/2.22.0
Content-Type: application/x-www-urlencoded
Content-Length: 23

json=["cmd_ls", [], {}]

json=["cmd_ls", [], {"show_licenses": True, "show_server": False, "expires": 15}]

import requests
import json

response = requests.post("http://127.0.0.1:1715/api", data={"json": json.dumps(["cmd_ls", (), {"show_licenses": True}])})
data = response.json()
licenses = data["licenses"]
for license in licenses:
    print("License: {} {}/{} {}".format(license["product"], license["available"], license["total_tokens"], license["version"]))

License: Houdini Apprentice 40/50 18.0
License: Houdini FX 74/100 18.0
License: Houdini Engine 20/200 18.0

"""
定期的に実行中のsesinetdから情報を要求してその情報を閲覧用にmysqlデータベースにダンプします。
"""

from __future__ import print_function
import sys
import requests
import argparse
import threading
import json
import mysql.connector
from datetime import datetime
import time

class Runner(object):
    def __init__(self):
        self.args = None

    def add_options(self, parser):
        parser.add_argument("--server", help="Server to request information from", default="localhost")
        parser.add_argument("--port", help="Server port number", default=1715)
        parser.add_argument("--interval", help="Interval to send requests.", default = 30)

    def server_url(self, route):
        return "http://{}:{}{}".format(self.args.server, self.args.port, route)

    def execute(self):
        # リクエスト全体のタイムスタンプが同じであることを確認します。
        timestamp = time.time()
        response = requests.post(self.server_url("/api"),
                             data={"json": json.dumps(["cmd_ls", (), {}])}
                            )

        db = mysql.connector.connect(
            host=<server>,
            user=<sql user>,
            password=<sql password>)

        cursor = db.cursor()

        sql_database = "CREATE DATABASE IF NOT EXISTS sesinetd"
        cursor.execute(sql_database)
        cursor.execute("USE sesinetd")
        db.commit()

        sql_table = "CREATE TABLE IF NOT EXISTS usage ( " \
                "id INT NOT NULL AUTO_INCREMENT PRIMARY KEY," \
                "timestamp INT," \
                "product VARCHAR(25) NOT NULL," \
                "available SMALLINT," \
                "total_tokens SMALLINT," \
                "version VARCHAR(10) NOT NULL," \
                "tokens_used SMALLINT);"
        cursor.execute(sql_table)
        db.commit()

        sql_table = "CREATE TABLE IF NOT EXISTS response_times ( " \
                "id INT NOT NULL AUTO_INCREMENT PRIMARY KEY," \
                "timestamp INT," \
                "response_time FLOAT);"
        cursor.execute(sql_table)
        db.commit()

        sql = "INSERT INTO usage (product, available, total_tokens, version, timestamp, tokens_used) VALUES (%s, %s, %s, %s, %s, %s);"
        data = response.json()
        licenses = data["licenses"]
        for license in licenses:
            product = license["product"]
            available = license["available"]
            total_tokens = license["total_tokens"]
            version = license["version"]
            cursor.execute(sql, (product, available, total_tokens, version, timestamp, (total_tokens - available)))
            db.commit()

        sql = "INSERT INTO response_times (timestamp, response_time) VALUES (%s, %s);"
        cursor.execute(sql, (timestamp, response.elapsed.total_seconds()))
        db.commit()

        cursor.close()
        db.close()


    def run(self):
        parser = argparse.ArgumentParser(
            description="Periodically request information from a running sesinetd"
                    " which is dumped into mysql.")
        self.add_options(parser)
        self.args = parser.parse_args()

        self.execute()

        interval = self.args.interval
        ticker = threading.Event()
        while not ticker.wait(interval):
            self.execute()


if __name__ == "__main__":
    runner=Runner()
    runner.run()