Event Functionの設定

import sys
sys.path.insert(0, 'lib')
import logging
import traceback
import requests
import zcatalyst_sdk
logger = logging.getLogger()
zbooksdomain = "{{YOUR_ZBOOKS_DOMAIN}}"; #リージョンに基づいたZoho Booksドメインを入力してください
zbooksorg = "{{YOUR_ZBOOKS_ORGANIZATION_ID}}" #Zoho BooksのOrganization IDを入力してください
zcliqdomain = "{{YOUR_ZCLIQ_DOMAIN}}"; #リージョンに基づいたZoho Cliqドメインを入力してください
zcliq_channel_unique_name = "{{YOUR_CHANNEL_UNIQUE_NAME}}" #更新を投稿するチャンネルのユニーク名を入力してください
zcliq_bot_unique_name = "{{YOUR_BOT_UNIQUE_NAME}}" #メッセージを投稿するボットのユニーク名を入力してください
zaccountsdomain = "{{YOUR_ZACCOUNTS_DOMAIN}}" #リージョンに基づいたZoho Accountsドメインを入力してください
def handler(event, context):
    try:
        data = extract_invoice_data(event)
        rows = transform_invoice_data(data)
        request_body = prepare_cliq_request(rows)
        access_token = get_access_token()
        send_to_cliq(request_body, access_token)
        logger.info("Message pushed to channel successfully")
        context.close_with_success()
    except Exception as e:
        logger.error("An unexpected error occurred:\n%s", traceback.format_exc())
        context.close_with_failure()
def extract_invoice_data(event):
    event_payload = event.get_raw_data()
    data = event_payload.get("data")
    rows = [invoice for invoices in data for invoice in invoices]
    return rows
def transform_invoice_data(rows):
    for row in rows:
        invoice_id = row.get("Invoice Id")
        row["Link"] = f"https://{zbooksdomain}/app/{zbooksorg}#/invoices/{invoice_id}"
        del row["Invoice Id"]
    return rows
def prepare_cliq_request(rows):
    request_body = {
        "slides": [{
            "type": "table",
            "data": {
                "headers": ["Customer", "Invoice Number", "Amount", "Paid On", "Link"],
                "rows": rows
            }
        }],
        "text": "Here are the invoices marked as Paid in the last hour:"
    }
    return request_body
def get_access_token():
    app = zcatalyst_sdk.initialize()
    connector_config = {
        "CliqConnector": {
            "client_id": "{{YOUR_CLIENT_ID}}", #Client IDを入力してください
            "client_secret": "{{YOUR_CLIENT_SECRET}}", #Client Secretを入力してください
            "auth_url": f"https://{zaccountsdomain}/oauth/v2/token",
            "refresh_url": f"https://{zaccountsdomain}/oauth/v2/token",
            "refresh_token": "{{YOUR_REFRESH_TOKEN}}" #Refresh Tokenを入力してください
        }
    }
    connector = app.connection(connector_config).get_connector("CliqConnector")
    access_token = connector.get_access_token()
    return access_token
def send_to_cliq(payload, access_token):
    cliq_channel_url = f"https://{zcliqdomain}/api/v2/channelsbyname/{zcliq_channel_unique_name}/message?bot_unique_name={zcliq_bot_unique_name}" 
    headers = {
        "Content-Type": "application/json",
        "Authorization": f"Zoho-oauthtoken {access_token}"
    }
    response = requests.post(cliq_channel_url, headers=headers, json=payload)
    response.raise_for_status()