git -C '/home/opc/rocketa.git' show f703852 -- oci_func_prod/log/func.py

commit f70385251317348253f5ebffeffc00e3a1d6d563
Author: Satoshi Ujihara <satoshi_ujihara@fivegate.jp>
Date:   Thu Jan 29 17:46:01 2026 +0900

    gitignore　更新
    compser.json　更新
    本番環境oci_func 作成

diff --git a/oci_func_prod/log/func.py b/oci_func_prod/log/func.py
new file mode 100644
index 0000000..7cce0c1
--- /dev/null
+++ b/oci_func_prod/log/func.py
@@ -0,0 +1,63 @@
+import io
+import json
+import logging
+import json
+import datetime
+import urllib.parse
+from sqlalchemy import create_engine, text
+
+from fdk import response
+
+logging.basicConfig(level=logging.INFO)
+
+int_param_list = {
+    'ad_id',
+    'client_id',
+    'amount',
+    'sales_count',
+    'stage',
+}
+
+
+def handler(ctx, data: io.BytesIO = None):
+    logging.info("handler started")
+    headers = ctx.Headers()
+
+    full_url = ctx.RequestURL()
+
+    DB_HOST = "api.rocket-a.com"
+    DB_USER = "root"
+    DB_PASSWORD = "buSDonry4%h6rm-0fy"
+    DB_NAME = "rocketa-api"
+
+    # 接続URLの作成: mysql+pymysql://user:password@host/dbname
+    DB_URL = f"mysql+pymysql://{DB_USER}:{DB_PASSWORD}@{DB_HOST}/{DB_NAME}"
+    engine = create_engine(DB_URL)
+    connection = engine.connect()
+
+
+    # 成果データ保存
+    sql_query  = 'INSERT INTO '
+    sql_query += ' logs '
+    sql_query += '( '
+    sql_query += '    log '
+    sql_query += ') VALUES ( '
+    sql_query += '   :log '
+    sql_query += ') '
+    params = {
+        "log": full_url if full_url else None,
+    }
+    result = connection.execute(text(sql_query), params)
+
+    # トランザクションをコミットして変更を永続化
+    connection.commit()
+
+    # 終了ステータス表示
+
+    return response.Response(
+        ctx,
+        status_code=200,
+        response_data=json.dumps('OK'),
+        headers={"Access-Control-Allow-Origin": "*","Access-Control-Allow-Headers": "Content-Type"}
+    )
+