Advanced I/O Functionの設定

import json
import zcatalyst_sdk
import logging
from flask import Request, make_response, jsonify
tableName = 'AlienCity'  # Data Storeに作成したテーブル
columnName = 'CityName'  # テーブルに作成したカラム
def handler(request: Request):
    try:
        app = zcatalyst_sdk.initialize()    # Catalyst SDKの初期化
        logger = logging.getLogger()
        if request.path == "/alien" and request.method == 'POST':   # 特定の都市のエイリアン遭遇を報告するPOST API
            req_data = request.get_json()
            name = req_data.get('city_name')
            rowid = getAlienCountFromCatalystDataStore(name)    # Catalyst Data Storeテーブルにクエリを実行し、指定された都市の行が存在するかどうかを確認します
            if len(rowid) == 0:         # 行が存在しない場合、新しい行を挿入します
                logger.info("Alien alert!")     # ログに記録されます。コンソールのMonitorセクションにあるLogsからこのログを確認できます
                datastore_service = app.datastore()
                table_service = datastore_service.table(tableName)
                row_data = {
                    columnName:name
                    }
                table_service.insert_row(row_data)  # Catalyst Data Storeテーブルに都市名を行として挿入します
                response = make_response(jsonify({
                "message": "Thanks for reporting!"
            }), 200)
            else:       # 行が存在する場合、重複を示すメッセージを送信します
                response = make_response(jsonify({
                "message": "Looks like you are not the first person to encounter aliens in this city! Someone has already reported an alien encounter here!"
            }), 200)
            return response
        elif request.path == "/alien" and request.method == 'GET':  # テーブルで該当都市のエイリアン遭遇を確認するGET API
            name = request.args.get('city_name')
            rowid = getAlienCountFromCatalystDataStore(name)    # Catalyst Data Storeテーブルにクエリを実行し、指定された都市の行が存在するかどうかを確認します
            if len(rowid) == 0:
                response = make_response({
                    "message": "Hurray! No alien encounters in this city yet!",
                    "signal": "negative"
                }, 200)
            else:
                response = make_response(jsonify({
                "message":  "Uh oh! Looks like there are aliens in this city!",
                "signal": "positive"
            }), 200)
            return response    
        else:
            response = make_response("Error. Invalid Request")
            response.status_code = 404
            return response
    except Exception as err:    # エラーレスポンスを送信します
        logger.error(f"Exception in AlienCityAIO :{err}")
        response = make_response(jsonify({
                 "error": "Internal server error occurred. Please try again in some time."
            }), 500)
        return response
def getAlienCountFromCatalystDataStore(cityname):   # 指定された都市のエイリアン遭遇が既に報告されているかどうかをData Storeテーブルにクエリを実行して確認します
        app = zcatalyst_sdk.initialize()   
        zcql_service = app.zcql()
        query = f"SELECT * FROM {tableName} WHERE {columnName} = '{cityname}'"
        output = zcql_service.execute_query(query)
        return output