LINEbotを初めて作っているのですが、フォローイベントの際にその人のスキーマをPostgreSQLで作る方法が分かりません。

Question

前提・実現したいこと

初めてLINEbotをPython,Herokuを用いて作っているのですが、フォローイベントの際にその人のユーザーID名のスキーマをPostgreSQlで作成する方法が分かりません。

該当のソースコード

from flask import Flask,request,abort
from linebot import LineBotApi,WebhookHandler
from linebot.exceptions import InvalidSignatureError
from linebot.models import MessageEvent,TextMessage,TextSendMessage,FollowEvent
import os
import psycopg2

app=Flask(__name__)

#環境変数の取得
YOUR_CHANNEL_ACCESS_TOKEN = os.environ["YOUR_CHANNEL_ACCESS_TOKEN"]
YOUR_CHANNEL_SECRET = os.environ["YOUR_CHANNEL_SECRET"]
line_bot_api=LineBotApi(YOUR_CHANNEL_ACCESS_TOKEN)
handler=WebhookHandler(YOUR_CHANNEL_SECRET)

@app.route("/callback",methods=["POST"]) 
def callback():
    signature=request.headers["X-Line-Signature"]
    body=request.get_data(as_text=True)
    app.logger.info("Request body"+body)
    try:
        handler.handle(body,signature)
    except InvalidSignatureError:
        abort(400)
    return "OK"

@handler.add(FollowEvent)
def handle_follow(event):
    your_id = event.source.user_id
　　message = "君のユーザーIDは{}だよ".format(your_id)
    line_bot_api.reply_message(event.reply_token,TextSendMessage(text=message))
    #まだその人のスキーマが作成されていなければ新規作成する。
    with psycopg2.connect("dbname=linebot user=postgres password=pass") as conn:
        with conn.cursor() as cur:
            cur.execute("CREATE SCHEMA IF NOT EXISTS {}".format(your_id))

if __name__=="__main__":
    port=int(os.getenv("PORT",5000))
    app.run(host="0.0.0.0",port=port)

試したこと

スキーマの作成だけでなくデータベースからのデータ取得などもできるか確認しましたができませんでした。
しかし「君のユーザーIDは○○だよ」というメッセージは届くので、Bot自体は動いていると思います。
また、with文のところのみを別に実行してみたところ、無事にスキーマを作成することが出来ました。
なのでAPIの使いかたを間違えているのかと思いましたが、リファレンスを読んでも原因を見つけることができませんでした。(もしかすると見落としてしまっているのかもしれません...。)
何か分かる方がいらっしゃれば、よろしくお願いします。

補足情報（FW/ツールのバージョンなど）

同階層のファイルです。

Procfile

web: python main.py

requirements.txt

Flask==0.12
line-bot-sdk==1.8.0
psycopg2==2.8.6

runtime.txt

python-3.9.2

Comments

[sazi]

質問に直接関係ありませんけど、postgresのロールでスキーマを分けて、独立させるという事ならまだしも、利用者のユーザー毎のスキーマを作る事にあまりメリットを感じませんが何故そうするのでしょう？

多分同一構造のテーブルをユーザー毎に持たせたいというような事だと思いますけど、ユーザー同士の繋がりを求めるような場合には、SQLレベルではデメリットしか無いと思うのですが。

[kento15]

ありがとうございます。
今回初めてデータベースを触ってみたので、上手な設計などを理解できていません。saziさんがおっしゃるように、ユーザーごとに同一構造のテーブルを作りたいのですが、どのような構成にするのがよいのでしょうか？教えてくださると助かります。

[sazi]

> ユーザーごとに同一構造のテーブルを作りたい
ユーザー毎に独立したサービスなら別ですが、そうでないなら止めておいた方が良いです。
テーブルにユーザーIDをキーとして追加したテーブル構造にしておいた方が良いでしょう。

[kento15]

なるほどです。確かにスキーマで分けてしまうと不便ですね...。
アドバイスありがとうございます。

Answer 1

Herkou PostgreSQLのDBに接続していたのではなく、自分で勝手に作ったDBに接続しようとしていたので動かなかったようです。

Answer 2

handle_follow()関数に、下記のデコレータ（handler.add～）を付ける必要があると思います。

@handler.add(FollowEvent)
def handle_follow(event):
    your_id = event.source.user_id
　　message = "君のユーザーIDは{}だよ".format(your_id)
(以下略)

Comments

[kento15]

ご指摘ありがとうございます。もともともコードにはデコレータも書いていたのですが、コピペし忘れていたようです。おかげで気づくことが出来ました。