Commit: c1f47a3d2115f927f8fe55f2e424f95b9111e114 - elixir_report_sample (git)

PythonからElixir Reportのレポートサーバーにアクセスするサンプルコード

Commit MetaInfo

• Revision: c1f47a3d2115f927f8fe55f2e424f95b9111e114 (tree)
• Time: 2014-12-03 01:19:15
• Author: Hiromichi Matsushima <hylom@Hiro...>
• Commiter: Hiromichi Matsushima

Log Message

add handler to get xml data from report server

Change Summary

• add: config.py
• modified: server_app.py

Incremental Difference

--- /dev/null
+++ b/config.py
@@ -0,0 +1,14 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+config = {
+    "report_server": {
+        "user": "admin",
+        "password": "sa",
+        "host": "127.0.0.1",
+        "port": 7001
+    },
+    "data_source": {
+        "traffic": "/WebAnalytics/"
+    }
+}

--- a/server_app.py
+++ b/server_app.py
@@ -1,20 +1,63 @@
 #!/usr/bin/python
 # -*- coding: utf-8 -*-
 
+import os
+from datetime import date, timedelta
+
 from tornado import ioloop
 from tornado import web
-import os
+
+from config import config
+from report_server import ReportServer
 
 # configurations
 CSS_PATH = os.path.join(os.getcwd(), "www_root/css")
 JS_PATH = os.path.join(os.getcwd(), "www_root/js")
 
 class MainHandler(web.RequestHandler):
+    "index.htmlを返すハンドラ"
     def get(self):
         self.render("index.html")
 
 
+class TrafficDataHandler(web.RequestHandler):
+    "トラフィックデータリクエストを処理するハンドラ"
+    def get(self):
+        try:
+            year = int(self.get_argument("y"))
+            month = int(self.get_argument("m"))
+        except ValueError:
+            self.send_err(400)
+            return
+
+        # パラメータで指定された年/月から
+        # 開始/終了年月日を生成する
+        start_date = date(year, month, 1)
+        if month == 12:
+            end_date = date(year + 1, 1, 1) + timedelta(-1)
+        else:
+            end_date = date(year, month + 1, 1) + timedelta(-1)
+
+        # レポートサーバーに投げるパラメータを作成
+        param = {
+            "start_date": start_date,
+            "end_date": end_date
+        }
+
+        # リクエスト送信
+        r = ReportServer(config["report_server"]["user"],
+                         config["report_server"]["password"],
+                         config["report_server"]["host"],
+                         config["report_server"]["port"])
+        xml = r.data(config["data_source"]["traffic"], param)
+        # 取得したXMLをクライアントに送信
+        self.set_header("Content-type", "application/xml")
+        self.set_status(200)
+        self.finish(xml)
+
+
 class DataTestHandler(web.RequestHandler):
+    "テスト用ハンドラ"
     def get(self, request_path):
         data_dir = os.path.join(os.getcwd(), "testdata")
         if request_path == "sample.xml":
@@ -45,8 +88,10 @@ class DataTestHandler(web.RequestHandler):
         else:
             self.send_error(404)
 
+
 application = web.Application([
     ("/", MainHandler),
+#    ("/data/traffic", TrafficDataHandler),
     ("/data/(.*)", DataTestHandler),
     ("/css/(.*)", web.StaticFileHandler, {"path": CSS_PATH}),
     ("/js/(.*)", web.StaticFileHandler, {"path": JS_PATH}),