Slackで社内文書検索 3/4回（Slackからのコマンドとメッセージの受信編）

関連記事

1. LangGraphとは

はじめに

この記事は、「Slackで社内文書検索 2/4回（Vertex AI Searchのアプリの作成とデータストアの自動更新編）」の続きです。 開発の流れは以下の通りです。

今回はSlackからのコマンドとメッセージの受信について説明していきます。

概要

今回は以下の処理のうち、コマンドとメッセージを送信からHTTPレスポンスを返すまでの処理を説明します。

Slackからのコマンドとメッセージの受信

GCPのプロダクトの都合上、Pub/Sub、Cloud Functionsの順で作成したほうが良いので、処理の流れとは逆に説明していきます。

1. トピックの作成

ここでは、コマンドとメッセージを保持する役割のPub/Subのトピックを作成します。

Pub/Sub は、メッセージを生成するサービスを、それらのメッセージを処理するサービスと切り離す、非同期のスケーラブルなメッセージング サービスです。

まず、GCPのPub/Subに移動し、トピックのページのトピックを作成を選択する。

次に、トピックの作成ページのトピックIDに任意の名前を入力して作成を選択します。トピックID以外はデフォルトのままにしています。

これでトピックの作成は終了です！ トピックIDは後ほど必要になるので控えておいてください。

2. リクエストを受け取り、HTTPレスポンスを返すファンクション

今回作成するファンクションの作成方法は前回の記事と変わらないので、こちらを参照してください。ただし、前回の記事と異なる部分があります。その部分は以下に従ってください。

SLACK_SIGNNG_SECRETの場所

1. Slack APIのページに移動

   https://api.slack.com/apps

2. 作成したアプリを選択

3. サイドバーのBasic Informationを選択

4. App CredentialsのSigning SecretのShowを押す

1. main.py

   :::details code

   import json
   import os
    
   import functions_framework
   from google.cloud import pubsub_v1
    
    
   PROJECT_ID = os.getenv("GOOGLE_CLOUD_PROJECT")
   publisher = pubsub_v1.PublisherClient()
   TOPIC_NAME = os.getenv("TOPIC_NAME")
    
    
   def publish_message(command, message):
    topic_path = publisher.topic_path(PROJECT_ID, TOPIC_NAME)
    message_json = json.dumps(
        {
            "data": {"command": command, "message": message},
        }
    )
    message_bytes = message_json.encode("utf-8")
    try:
        publisher.publish(topic_path, data=message_bytes)
        return "Message published."
    except Exception as e:
        print(e)
        return (e, 500)
    
    
   @functions_framework.http
   def slack_event(request):
    	# リクエストからcommandを取り出す
    command = request.form.get("command")
    	# リクエストからメッセージ部分を取り出す
    text = request.form.get("text")
    publish_message(command, text)
    return "Message received successfully"

   :::

2. requirements.txt

   :::details code

   functions-framework==3.*
   slack-bolt==1.13.0
   python-box[all]~=6.0
   google-cloud-pubsub==2.7.0
   langchain==0.0.175
   llama-index==0.6.9
   pytz
   html2text

   :::

3. エントリポイント

4. slack_eventに変更

:::

以上でファンクションの作成は終了です！ ファンクションの作成後、Slack APIのコマンドのRequest URLで使用するURLを取得します。 Cloud Functionsで作成したファンクションを選択すると、その画面の中にURLが表示されるので、それをコピーします。

コピーしたURLはコマンドのRequest URLに張り付けてください。

これで、Slackからのリクエストからメッセージとコマンドと取り出して、Pub/Subにその内容をパブリッシュすることができます！ 検証として、Slackからコマンドとメッセージを送信して、Cloud FunctionsやPub/Subのログにリクエストやメッセージが残るか確かめてみてください。

最後に

今回は、Slackからのコマンドとメッセージの受信について説明しました。Pub/Subを用いて、Slack APIの３秒レスポンスルールへの対応を取りました！また、今回作成したファンクションのURLをSlackで社内文書検索 1/4回（Slack APIアプリの作成と設定編）のRequest URLに用いることを注意してください。次は任意のLLMによる回答生成について説明します。

参考

https://cloud.google.com/pubsub/docs/overview?hl=ja