こんにちは！インサイトテクノロジーの松尾です。
本記事では、Denodo Platform 9.1 の新機能「Denodo AI SDK」を Slack から利用する手順をご紹介します。
先日の記事では、Denodo AI SDK のチャットボットサンプルを動かす方法をご紹介しました。
しかし、専用アプリではなく、普段使いのツール（例: Slack）から使いたい方も多いのではないでしょうか？
そこで、Denodo 公式ドキュメントを参考に、Slack との連携を試してみました。この記事では、その手順を詳しく説明します。
私の実行環境
- Windows 11 24H2
- WSL2 Ubuntu 22.04.5 LTS
- Slack フリープラン
アーキテクチャ概要
動作確認のため、以下のアーキテクチャで構築しました。
動作は以下の通りです。
- Slackからのメッセージは、ローカル PC 上で動作する Python プログラム（"Slack IF"）で処理します
- "Slack IF"が Denodo AI SDK にリクエストを送信します
- Denodo AI SDKは、Denodo Platform および生成 AI から回答を生成します
- 最終的に "Slack IF" が Slack に応答を返します
ではさっそく進めていきましょう。
Slack と Python プログラム（ "Slack IF" ）のやり取り
まず、Slack と Python プログラムがメッセージをやり取りできるよう設定します。この部分は Denodo とは直接関係なく、Slack 社の公式ドキュメントに基づいて進めます。ローカル PC と Slack のやり取りの方法として Denodo 社の記事では localtunnel を使って Flask とやり取りするような手順となっていますが、本投稿では Slack 社のドキュメントに従い Socket Mode を使って行います。まずは、以下のドキュメントに従い、ローカルの Python コードが Slack とやり取りできるようにしてみましょう。
Slack アプリの作成
まず、「Create New App」からアプリを追加します。
「From scratch」を選択します。
アプリ名を入力し、ワークスペース名を選択し、「Create App」を選択します。
トークンの作成
必要なトークン(ボットトークンとアプリレベルトークン)を作成します。
左から「OAuth & Permissions」を選択し、「Bot Token Scopes」で「Add an OAuth Scope」を選択します。
chat:write というのを探して追加します。
一番上の「Install App to Workspace」を選択します。表示される画面で指定したワークスペースへのアプリのインストールを実行します。
「Bot User OAuth Access Token」が確認できます。
この xoxb-xxxxxxxxxxxxxxxxxxx がボットトークンです。
続いて、「Basic Informationのページ」で、アプリレベルトークンの「Generate Token and Scopes」を選択し、アプリレベルトークンを作成します。このトークンに connections:write のスコープを付与します。
アプリレベルトークン xapp-xxxxxxxxxxxxxxxxxxxxxx が生成されました。
Socket Mode の有効化とイベントサブスクリプションの設定
左のメニューから Socket Mode を選択し、「Enable Socket Mode」から Socket Mode を有効にします。
参照するイベントを設定します。「Event Subscriptions」を選択します。
以下のように、Scope を選択し、下部にある「Save Changes」を選択して保存します。
これで準備は整いました。
念のため、以下からアプリを再起動します。
上記再インストールの手順はドキュメントへの記載はありませんが、私が実施したときは再インストールしないと動作しなかったので、念のため、、
Python プログラムの実行
参考ページ に記載されている以下のサンプルを実行してみましょう。
import os
from slack_bolt import App
from slack_bolt.adapter.socket_mode import SocketModeHandler
# ボットトークンを渡してアプリを初期化します
app = App(token=os.environ.get("SLACK_BOT_TOKEN"))
# 'こんにちは' を含むメッセージをリッスンします
# 指定可能なリスナーのメソッド引数の一覧は以下のモジュールドキュメントを参考にしてください：
# https://tools.slack.dev/bolt-python/api-docs/slack_bolt/kwargs_injection/args.html
@app.message("こんにちは")
def message_hello(message, say):
# イベントがトリガーされたチャンネルへ say() でメッセージを送信します
say(f"こんにちは、<@{message['user']}> さん！")
if __name__ == "__main__":
# アプリを起動して、ソケットモードで Slack に接続します
SocketModeHandler(app, os.environ["SLACK_APP_TOKEN"]).start()
以下のようにトークンを環境変数セットしてから実行します。
(venv) $ export SLACK_APP_TOKEN=xapp-xxxxxxxxxxxxxxxxxxx
(venv) $ export SLACK_BOT_TOKEN=xoxb-xxxxxxxxxxxxxxxxxxx
(venv) $ python3 app.py
⚡️ Bolt app is running!
そして、Slack から以下のように「こんにちは」と呼び掛けると、応答が返ってきます。
このサンプルは「こんにちは」という文字列が入っているメッセージに反応するようになっています。
毎回「こんにちは」と入力するのも面倒なので、すべてのメッセージに反応するよう、以下のように作り替えておきましょう。
11c11
< @app.message("こんにちは")
---
> @app.event("message")
すると、すべてのメッセージに反応するようになります。
Denodo AI SDK への問い合わせと返信処理の追加
Denodo AI SDK の起動
もちろん、事前に Denodo AI SDK を起動しておく必要があります。起動は以下の記事を参考に Docker で起動するのが手っ取り早いです。
$ docker compose -f docker-compose-sample-chatbot.yml up
で起動します。
Denodo AI SDK への問い合わせ処理と返信処理の実装
Python プログラムに Denodo AI SDK への問い合わせ処理を Denodo 社のサンプルに従って組み込みます。
以下は、質問を Denodo AI SDK に送信し、その結果を取得する例です。
import os
import requests;
from requests.auth import HTTPBasicAuth
from slack_bolt import App
from slack_bolt.adapter.socket_mode import SocketModeHandler
# ボットトークンを渡してアプリを初期化
app = App(token=os.environ.get("SLACK_BOT_TOKEN"))
# 質問を Denodo AI SDK へ投げて応答を返却
def call_answer_question_api(question):
url = "http://localhost:8008/answerQuestion"
params = {
"question": question,
}
response = requests.get(url, params=params, auth=HTTPBasicAuth('admin', 'admin'))
if response.status_code == 200:
data = response.json()
print(data)
return f"{data['answer']}\n{data['sql_query']}"
else:
response.raise_for_status()
# Error events
@app.error
def error_handler(error, body, logger):
logger.error(f"Error: {error}")
# メッセージに対する処理
@app.event("message")
def handle_message_events(body, say):
event = body['event']
user_input = event.get('text')
response = call_answer_question_api(user_input)
say(response)
if __name__ == "__main__":
# アプリを起動して、ソケットモードで Slack に接続
SocketModeHandler(app, os.environ["SLACK_APP_TOKEN"]).start()
すると以下のように、Slack から Denodo AI SDK とやり取りできるようになりました！
おわりに
本記事では、Denodo AI SDK を Slack から操作する手順を、Denodo 社のドキュメントを参考に紹介しました。専用の UI を使用せず、普段使いのツールから操作できることで、利用の敷居が大きく下がると感じています。
今回は動作確認のサンプル構築にとどまりましたが、Slack を介して Denodo のデータを直接クエリーできる未来を想像すると、とてもワクワクしますね！
もう少し詳しく知りたい方へ
弊社インサイトテクノロジーは、Denodo 社の公式パートナーとして、Denodo Platform の紹介、販売、導入支援を行っています。ご興味のある方は、ぜひ以下のリンクからお問い合わせください。
また、「これからデータ統合基盤を整備したい」「どのようにデータを統合すればよいか迷っている」といった初期段階のお悩みや、「現在進行中のプロジェクトで特定の課題がある（例: Snowflake に SAP からリアルタイムデータを取り込みたい）」といった具体的なご相談も、ぜひお気軽にお問い合わせください。