ZapierでkintoneからZendeskにファイルアップロードする話 ～終!?:kintone記事エディターシリーズ～

import json

return json.loads(input["webhook_body"])

from io import BytesIO
from functools import partial
import json
import requests
import urllib.parse
import re
import asyncio


async def get_kintone_attachment(attachment):
    url = "https://{}.cybozu.com/k/v1/file.json?fileKey={}"
    download_api_url = url.format(input["KINTONE_SUB_DOMAIN"], attachment["fileKey"])
    headers = {"X-Cybozu-API-Token": input["KINTONE_API_TOKEN"]}

    loop = asyncio.get_event_loop()
    response = await loop.run_in_executor(
        None, partial(requests.get, download_api_url, headers=headers)
    )
    return BytesIO(response.content)


async def create_article_attachment(article_id, attachment, upload_file):
    create_attachment_api = (
        "https://{}.zendesk.com/api/v2/help_center/articles/{}/attachments.json"
    )
    attachment_api_url = create_attachment_api.format(
        input["ZENDESK_SUB_DOMAIN"], article_id
    )

    auth_token = input["ZENDESK_AUTH_TOKEN"]
    headers = {"Authorization": "Basic {}".format(auth_token)}

    # インライン表示する画像ファイルか
    is_inline_image = attachment["contentType"].find("image/") > -1
    payload = {"inline": is_inline_image}
    files = {"file": (attachment["name"], upload_file)}

    loop = asyncio.get_event_loop()
    response = await loop.run_in_executor(
        None,
        partial(
            requests.post,
            attachment_api_url,
            headers=headers,
            data=payload,
            files=files,
        ),
    )

    # インラインファイルでなければコンテンツURLは返さない
    if not is_inline_image:
        return ""

    create_result = json.loads(response.text)
    article_attachment = create_result["article_attachment"]
    return article_attachment["content_url"]


async def kintone_to_zendesk_attachement(file_name, attachment):
    # kintoneからファイルダウンロード
    upload_file = await get_kintone_attachment(attachment)

    # zendeskへファイルアップロード
    article_id = input["ARTICLE_ID"]
    content_url = await create_article_attachment(article_id, attachment, upload_file)
    return {"file_name": file_name, "zendesk_content_url": content_url}


# webhook通知内容を読み込む
kintone_webhook = json.loads(input["webhook_body"])

# app_id
app_id = kintone_webhook["app"]["id"]

# レコード番号
kintone_record = kintone_webhook["record"]
record_id = kintone_record["$id"]["value"]

# kintoneの添付ファイル
record_attachments = kintone_record["添付ファイル"]["value"]

# markdownのテキスト
markdown_text = kintone_record["markdown_text"]["value"]

# アップロード対象外の画像
exclude_attachments = []

# アップロード処理のtaskリスト
loop = asyncio.get_event_loop()
upload_tasks = []

# 添付ファイル分アップロード
for attachment in record_attachments:

    # イメージファイルか
    is_image_file = attachment["contentType"].find("image/") > -1

    # ファイル名
    file_name = urllib.parse.quote(attachment["name"])

    markdown_pattern = "\(.*/k/api/record/download.do/-/{}\?app={}.*&record={}.*?\)".format(
        file_name, app_id, record_id
    )
    # markdownでインラインイメージとして利用されていない画像を保持
    if is_image_file and re.search(markdown_pattern, markdown_text) is None:
        exclude_attachments.append({"fileKey": attachment["fileKey"]})
        continue

    # kintoneからZendeskへのアップロード処理をタスクとして保持
    upload_task = loop.create_task(
        kintone_to_zendesk_attachement(file_name, attachment)
    )
    upload_tasks.append(upload_task)


# 転送処理を非同期実行
gather = asyncio.gather(*upload_tasks)
upload_results = loop.run_until_complete(gather)
loop.close()

return {
    "exclude_attachments": json.dumps(exclude_attachments),
    "upload_results": json.dumps(upload_results),
}