以前遇到一個情況阿，使用者輸入，我要ㄧ個漢堡，二杯奶茶，到後台卻變成，我要\xe3\x84\xa7個漢堡，二杯紅茶，截圖拍給我，很正常是ㄧ個漢堡，看了半天沒看出什麼鬼，最後發現

這個《ㄧ》個漢堡的一，是注音符號的《ㄧ》，你永遠不知道使用者會用什麼方式打字，在互動式的設計下，你會需要保留原始的對話紀錄，以應對各種神祕的輸入法所造成的問題，這邊要依據先前創建的Line Bot進行資料紀錄

Postgres 初始化 & 連線

新增Postgres模組到你的專案

使用免費方案hobby-dev

heroku addons:create heroku-postgresql:hobby-dev

用heroku pg:info檢查Postgres資料庫狀態

Plan:                  Hobby-dev
Status:                Available
Connections:           5/20
PG Version:            13.4
Created:               2021-09-27 02:30 UTC
Data Size:             8.1 MB/1.00 GB (In compliance)
Tables:                1
Rows:                  3/10000 (In compliance)
Fork/Follow:           Unsupported
Rollback:              Unsupported
Continuous Protection: Off
Add-on:                postgresql-dimensional-#####

建立表格

可以使用pgAdmin 4進行這個步驟，在dashboard內的addons，可以找到Heroku Postgres，Settings，Database Credentials會有從本機連線到資料庫的所需資訊

CREATE TABLE IF NOT EXISTS public.messaging_log
(
    id text COLLATE pg_catalog."default" NOT NULL,
    type text COLLATE pg_catalog."default" NOT NULL,
    text text COLLATE pg_catalog."default",
    datetime timestamp with time zone NOT NULL,
    source_uid text COLLATE pg_catalog."default" NOT NULL,
    source_type text COLLATE pg_catalog."default" NOT NULL,
    CONSTRAINT messaging_log2_pkey PRIMARY KEY (id)
)

TABLESPACE pg_default;

連線

如果你的App與Postgres在相同的專案下，在App內與資料庫連線時，你不需要特別設定資料庫連線的URL、使用者名稱、密碼等，在跨專案運作時請參考官方文件

安裝連線Driver

pip install psycopg2-binary

安裝完Addons你的Vars變數內會自動追加DATABASE_URL

DATABASE_URL = os.environ['DATABASE_URL']
conn = psycopg2.connect(DATABASE_URL, sslmode='require')

測試連線，看能否執行查詢資料庫版本指令

cur = conn.cursor()
cur.execute('SELECT VERSION()')
rr = cur.fetchall()
app.logger.debug(f"DBver:{rr}")
# "Database Version: [('PostgreSQL 13.4 (Ubuntu 13.4-1.pgdg20.04+1) on x86_64-pc-linux-gnu, compiled by gcc (Ubuntu 9.3.0-17ubuntu1~20.04) 9.3.0, 64-bit',)]"
conn.commit()
cur.close()

紀錄Line對話

藉由解析Webhook Event Objects可以從使用者的對話中取得如下資訊

1. 訊息類型
2. 訊息ID
3. 訊息文字(如果是文字訊息)
4. 訊息來源
5. 訊息來源使用者ID
6. 使用者的顯示名稱....
7. 以millisecond計算的Timestamp

prof = line_bot_api.get_profile(event.source.user_id)
dt = datetime.fromtimestamp(event.timestamp / 1000.0).astimezone(TWT)
format_time = dt.strftime("%Y/%m/%d %H:%M:%S")
app.logger.debug(f"message:{event.message.type}-{event.message.id} = {event.message.text}, from {event.source.type}:{prof.display_name}({event.source.user_id}) at {format_time}")
# [DEBUG] message:text-<訊息ID> = 王大明愛吃漢堡包, from user:<使用者的顯示名稱>(<訊息來源使用者ID>_ at 2021/09/28 17:53:00

將對應的參數填入Sql變數

def INS_msg_log(self, id, msgtype, text, dt, stype, suid):
  cur = self.conn.cursor()
  query = sql.SQL("INSERT INTO {}(id, type, text, datetime, source_uid, source_type) VALUES(%s, %s, %s, %s, %s, %s)").format(sql.Identifier('messaging_log'))
  cur.execute(query, (id, msgtype, text, dt, suid, stype))
  self.conn.commit()
  cur.close()

dbpm.INS_msg_log(event.message.id, event.message.type, event.message.text, dt.isoformat(), event.source.type, event.source.user_id)

如果運作正常，你就可以在資料庫查詢到每一筆使用者的訊息

Summary

你有沒有注意到，使用者名稱如果想儲存的話，是不是每一筆訊息都要查詢一次，這樣對話量一多會頻繁的向Line官方送出API請求，很容易造成被Ban，明天做一個UID與名稱對應表格吧