[BwAI workshop][Golang] LINE OA + CloudFunction + GeminiPro + Firebase = 旅行小幫手 LINE 聊天機器人(2): Firebase Database 讓 LINEBot 有個超長記憶

image-20240413210750427

前言:

這是一篇為了 04/18 跟 Google Developer Group 合作的 BUILD WITH AI (BWAI) WORKSHOP 的第二篇系列文章(不知道還需要幾篇)。

本篇文章將專注在以下幾個部分:

  • Firebase Database 設定
  • 如何在 Cloud Function 上透過官方 Golang 存取 Firebase
  • 透過 Firebase Database 來讓你的 Gemini 記住所有講過的事情,優化上一次打造的 LINE Bot

文章列表:

事前準備

  • LINE Developer Account: 你只需要有 LINE 帳號就可以申請開發者帳號。
  • Google Cloud Functions: GGo 程式碼的部署平台,生成供 LINEBot 使用的 webhook address。
  • Firebase:建立Realtime database,LINE Bot 可以記得你之前的對話,甚至可以回答許多有趣的問題。
  • Google AI Studio:可以透過這裡取得 Gemini Key 。

申請 Firebase Database 服務

  • 記得到 Firebase Console,並且建立一個專案 。

  • 建立一個 Firebase Realtime Database 等等會用到

    image-20240413212830827

  • 地區選美國

    image-20240413212903957

  • Start in “lock mode”

  • 為了開發方便,到 “Rules”設定成可以寫跟讀取,千萬注意:

    • 這是為了測試,請勿用在對外環境
    • 這是為了測試,請勿用在對外環境
    • 這是為了測試,請勿用在對外環境

image-20240413213202354

  • 記住哪個 URL (注意!之後要正式上線,需要改回權限),並且加上一個項目: “BwAI

image-20240413213802313

申請 Services Account Credential 讓 Cloud Function 連接 Google 服務

這部分的教學,其實可以參考我另外一篇文章。[學習文件] 如何在 Heroku 上面使用透過 Golang 來存取 Google Cloud 服務,但是這邊還是快速走一次。

  • 進入 Google Cloud Console ,到 IAM & Admin 選擇建立 Services Account

image-20240413221505536

  • Services Account Name 自己決定,要注意好 (上面專案跟 Firebase 專案名稱要一致)

image-20240413222847247

  • Grant this service account access to project 在身份的時候,建議先用 Editor (比較大,需要小心使用)

image-20240413223055288

  • “Grant users access to this service account” 不需要特別設定
  • 按下 “Manage Keys” 來準備下載 Credential

image-20240413223225404

  • 選擇 Add Key -> Create new Key -> 下載 JSON

image-20240413223613244

使用 Golang Google Options 套件需要注意:

雖然已經將 Firebase Realtime Database 設定成每個人都可以讀寫,但是如果是透過 Golang 去存取的時候,你會出現 Unauthorized request 的錯誤訊息。 這時候就是因為你的 JSON 檔案的 Project 跟你的 Firebase Project 是不同的。 只要重新建立一個 Services Account 並且更新 JSON 內容即可。

image-20240413220630196

如何在 Google Cloud Function 導入 Services Account Credential ?

接下來會來分享,要如何正確地能夠在 Cloud Function 內使用呢。 如果你想要直接使用 Cloud Function 去開啟 Credential JSON 檔案,你會一直得到無法正確拿到 credential 的錯誤訊息。

這時候需要先透過環境參數來加入:

  • 將 JSON 檔案中所有內容複製起來
  • 設定 GOOGLE_APPLICATION_CREDENTIALS 參數,然後把所有內容貼上環境參數。

image-20240413225710980

  • 接下來會跟大家講,如何修改相關程式碼?
	// Init firebase related variables
	ctx := context.Background()
	opt := option.WithCredentialsJSON([]byte(os.Getenv("GOOGLE_APPLICATION_CREDENTIALS")))
	config := &firebase.Config{DatabaseURL: os.Getenv("FIREBASE_URL")}
	app, err := firebase.NewApp(ctx, config, opt)
	if err != nil {
		log.Fatalf("error initializing app: %v", err)
	}
	client, err := app.Database(ctx)
	if err != nil {
		log.Fatalf("error initializing database: %v", err)
	}
  • 首先option.WithCredentialsJSON([]byte(os.Getenv("GOOGLE_APPLICATION_CREDENTIALS"))) 可以讓你從環境參數讀取到 credential 。
  • 接下來 &firebase.Config{DatabaseURL: os.Getenv("FIREBASE_URL")} 則是將 FIREBASE_URL 內容設定好。
  • 這樣就可以正確執行了,接下來要來看相關處理 Gemini 聊天記憶的部分了。

Gemini Pro Chat History 要如何正確處理?

首先也要讓大家了解一下,跟 OpenAI 不同的是: Gemini Chat History 的格式不太一樣(也不是很好了解)。根據網頁資料如下:

[parts {
   text: "In one sentence, explain how a computer works to a young child."
 }
 role: "user",
 parts {
   text: "A computer is like a very smart machine that can understand and follow our instructions, help us with our work, and even play games with us!"
 }
 role: "model"]

不是很確定為何 “parts” 會用集合, anyway 在 Python 中還不算難處理,但是在 Golang 裡面的處理方式如下:(參考自 Google Golang GAI Github https://github.com/google/generative-ai-go)

func ExampleChatSession_history() {
	ctx := context.Background()
	client, err := genai.NewClient(ctx, option.WithAPIKey(os.Getenv("GEMINI_API_KEY")))
	if err != nil {
		log.Fatal(err)
	}
	defer client.Close()
	model := client.GenerativeModel("gemini-1.0-pro")
	cs := model.StartChat()

	cs.History = []*genai.Content{
		&genai.Content{
			Parts: []genai.Part{
				genai.Text("Hello, I have 2 dogs in my house."),
			},
			Role: "user",
		},
		&genai.Content{
			Parts: []genai.Part{
				genai.Text("Great to meet you. What would you like to know?"),
			},
			Role: "model",
		},
	}

	res, err := cs.SendMessage(ctx, genai.Text("How many paws are in my house?"))
	if err != nil {
		log.Fatal(err)
	}
	printResponse(res)
}

問題來了, cs.History 竟然是對應到 []*genai.Content。這並不是一個對於 JSON unmarshall 就能夠直接使用的資料格式。還需要有相關的轉換。

透過 Firebase Database 處理 Chat History 的流程:

這邊稍微讓大家知道一下,由於 Firebase Database 其實就是一大包的 JSON Database 。你可以直接存取一整包的 JSON Structure 進這個資料庫。 這樣來說讓整個資料庫處理上,還有寫小型 POC 應用來說相當的方便。(但是效率是可以討論的)

// Define your custom struct for Gemini ChatMemory
type GeminiChat struct {
	Parts []string `json:"parts"`
	Role  string   `json:"role"`
}

.....

	// Get chat history from Firebase
	var InMemory []GeminiChat
	err = fireDB.NewRef("BwAI").Get(ctx, &InMemory)
	if err != nil {
		fmt.Println("load memory failed, ", err)
	}

	fmt.Println("InMemory: %v", InMemory)

	// convert InMemory to Memory
	for _, c := range InMemory {
		parts := make([]genai.Part, len(c.Parts))
		for i, part := range c.Parts {
			parts[i] = genai.Text(part)
		}
		dst := &genai.Content{
			Parts: parts,
			Role:  c.Role,
		}

		Memory = append(Memory, dst)
	}

上面是從 Firebase Database 取出後需要轉換的程式碼,但是使用方式則是直接將 Memory 直接交給 chat.History 即可。需要記得的是,在處理完之後,要把這一次的對話也放進 Memory之中。部分程式碼如下:

				// Pass the text content to the gemini-pro model for text generation
				model := client.GenerativeModel("gemini-pro")
				cs := model.StartChat()
				cs.History = Memory

				res, err := cs.SendMessage(ctx, genai.Text(req))
				if err != nil {
					log.Fatal(err)
				}
				var ret string
				for _, cand := range res.Candidates {
					for _, part := range cand.Content.Parts {
						ret = ret + fmt.Sprintf("%v", part)
						log.Println(part)
					}
				}

				// Save the conversation to the memory
				Memory = append(Memory, &genai.Content{
					Parts: []genai.Part{
						genai.Text(req),
					},
					Role: "user",
				})

				// Save the response to the memory
				Memory = append(Memory, &genai.Content{
					Parts: []genai.Part{
						genai.Text(ret),
					},
					Role: "model",
				})

				// Save the conversation to the firebase
				err = fireDB.NewRef("BwAI").Set(ctx, Memory)
				if err != nil {
					fmt.Println(err)
					return
				}

重點就在:

  • 要把之前講過的話,放入 History
  • 把現在講過的,直接丟給 cs.SendMessage()
  • 最後要記得把後來使用者輸入的文字,跟 Gemini 回覆的文字都加入 Memory

成果與使用 ChatSession 差異:

image-20240413210750427

可以直接看到成果相當的好,並且這樣的記憶長度就會看 Gemini Model Token 的限制,算是相當的好用。

那這個又跟 Gemini Chat Session 有什麼差別呢?

  • Chat Session: 適合使用在 Cloud Run 那種有固定一整台 server 的 LINE Bot 應用。
  • Firebase Database + Chat Session: 就可以放在 Cloud Function 這種 Functional As A Services 上面。

接下來:

感謝各位的支持,接下來就是要透過 Gemini Vision 去識別並且翻譯收據。還要讓 Gemini 可以快速幫我們找出哪時候買的? 什麼地方買的? 當初花了多少錢的「收據小幫手」。

完整原始碼

你可以在這裡找到相關的開源程式碼: https://github.com/kkdai/linebot-cf-firebase

[BwAI workshop][Golang] LINE OA + CloudFunction + GeminiPro + Firebase = 旅行小幫手 LINE 聊天機器人(一): 景色辨識小幫手

image-20240412221312444

前言:

這是一篇為了 04/18 跟 Google Developer Group 合作的 BUILD WITH AI (BWAI) WORKSHOP 的第一篇系列文章(不知道還需要幾篇),裡面包含了完整的 LINE 開發者相關帳號設定與 GCP 相關設定,只需要有付費認證帳號,其實是不會花費到任何錢的。

文章列表:

事前準備:

  • LINE Developer Account: 你只需要有 LINE 帳號就可以申請開發者帳號。
  • Google Cloud Functions: GGo 程式碼的部署平台,生成供 LINEBot 使用的 webhook address。
  • Firebase:建立Realtime database,LINE Bot 可以記得你之前的對話,甚至可以回答許多有趣的問題。
  • Google AI Studio:可以透過這裡取得 Gemini Key 。

關於 Gemini API Price

根據官方網站: https://ai.google.dev/pricing?hl=zh-tw

image-20240410164827279

申請 Gemini API Key

  • 到 Google AI Studio https://aistudio.google.com/
  • Click “Get API Key”
  • 選擇你已經有綁定信用卡的付費帳號,來取得 API Keyimage-20240412195805278

申請一個 LINE 聊天機器人 (Messaging API)

image-20240410165008871

  • LINE Developer Console )並且登入 image-20240410165104899
  • 在挑選 Channel 的時候,如果要申請 LINE Chatbot (官方帳號),就要申請 Messaging API image-20240410170120876
  • 相關資料填寫上:
    • Cmpany or owner’s country or region:
    • Channel Name: 也就是你的 LINE Bot 名稱。
    • Channel description: 相關敘述來描述你 LINE Bot 做什麼。
    • 其他都可以隨便填寫即可。
  • 接下來要到 Messaging API Tab 執行以下設定:
    • Auto-reply messages: 關閉它 image-20240410170924360
  • 接下來要取得兩個重要的參數:
    • Basic Setting Tab 下方的 Channel secret image-20240410171544805
    • Messaging API Tab 下方的 Channel access token (long-lived) image-20240410171731815
  • 目前先到這邊,稍後還會回來設定相關 Webhook 。

建立一個新的 Google Cloud Function

雖然 Google Cloud Function 跟 Firebase Realtime database 都是有免費額度的,但是可能你還是需要有一個付費帳號。也就是說你的 Google Cloud Account 需要填寫上你的信用卡資訊(有效的帳單帳戶)

關於 Cloud Function (cloud function 第 1 代) 的費用部分

根據網站定價,基本上在以下的狀況是不需要費用的。白話文來說

免費方案
Cloud Functions 針對運算時間資源提供永久免費方案,當中包括 GB/秒和 GHz/秒的分配方式。除了 200 萬次叫用以外,這個免費方案也提供 400,000 GB/秒和 200,000 GHz/秒的運算時間,以及每月 5 GB 的網際網路資料傳輸量。免費方案的使用額度,是以上述級別 1 價格的同等美元金額計算。無論執行函式的區域採用的是級別 1 和/或級別 2 價格,系統都會分配同等美元金額給您。不過在扣除免費方案的額度時,系統將以函式執行區域的級別 (級別 1 或級別 2) 為準。

請注意,即便您採用的是免費方案,也必須擁有有效的帳單帳戶。

Cloud Function 這邊,開始建立一個 Cloud Functions ,相關設定參考以下:

  • 環境: 第 1 代
  • 函式名稱: 隨便填
  • 地區: asia-east1 (台灣)
  • HTTP
    • 驗證: 允許未經驗證的叫用

image-20240410174823233

  • 執行階段、建構作業、連線和安全性設定
    • 不需要修改,先使用 256MB 記憶體是足夠的。
  • 執行階段環境變數
    • 開始設定以下變數:
      • GOOGLE_GEMINI_API_KEY: 剛剛取得的 Gemini API Key
      • ChannelAccessToken: 在 LINE Developer Console 取得的 Channel Access Token
      • ChannelSecret: 在 LINE Developer Console 取得的 Channel Secret

image-20240412200122236

開始修改 Cloud Function 的程式碼

  • 別忘記 “go.mod” 也要跟著修改,請複製這一段完整程式碼

  • 按下「部署」,然後等待一下。
  • 部署好之後,記得到「觸發條件」進去查詢「觸發網址」 ,記得複製這個網址,等等需要使用。

image-20240412214423901

LINE Bot 完成最後設定

  • 到 “Messaging API” Tab
  • 填入 “Webhook URL” 數值,將剛剛得「觸發網址填上去」
  • 更新(update)後,使用 “Verify” 看看有沒有設定錯誤。
  • 如果沒有問題,可以打開「Use webhook」

image-20240412214745544

來測試吧

image-20240412221246422

完整原始碼

你可以在這裡找到相關的開源程式碼: https://github.com/kkdai/linebot-cloudfunc-gemini-go

[Golang][GCP] 在 Cloud Function 上面透過 Golang 操控 Firebase Database 需要注意與可能踩雷的地方

前提:

本篇文章將快速走過一次,如何申請 GCP Services Account Credential ,還有如何在 Cloud Function 使用這樣的資料,最後如何透 Golang 來在 Cloud Function 操控 Firebase Database ,還有可能發生的雷點。

申請 Services Account Credential 讓 Cloud Function 連接 Google 服務

這部分的教學,其實可以參考我另外一篇文章。[學習文件] 如何在 Heroku 上面使用透過 Golang 來存取 Google Cloud 服務,但是這邊還是快速走一次。

  • 進入 Google Cloud Console ,到 IAM & Admin 選擇建立 Services Account

image-20240413221505536

  • Services Account Name 自己決定,要注意好 (上面專案跟 Firebase 專案名稱要一致)

image-20240413222847247

  • Grant this service account access to project 在身份的時候,建議先用 Editor (比較大,需要小心使用)

image-20240413223055288

  • “Grant users access to this service account” 不需要特別設定
  • 按下 “Manage Keys” 來準備下載 Credential

image-20240413223225404

  • 選擇 Add Key -> Create new Key -> 下載 JSON

image-20240413223613244

使用 Golang Google Options 套件需要注意:

雖然已經將 Firebase Realtime Database 設定成每個人都可以讀寫,但是如果是透過 Golang 去存取的時候,你會出現 Unauthorized request 的錯誤訊息。 這時候就是因為你的 JSON 檔案的 Project 跟你的 Firebase Project 是不同的。 只要重新建立一個 Services Account 並且更新 JSON 內容即可。

image-20240413220630196

如何在 Google Cloud Function 導入 Services Account Credential ?

接下來會來分享,要如何正確地能夠在 Cloud Function 內使用呢。 如果你想要直接使用 Cloud Function 去開啟 Credential JSON 檔案,你會一直得到無法正確拿到 credential 的錯誤訊息。

這時候需要先透過環境參數來加入:

  • 將 JSON 檔案中所有內容複製起來
  • 設定 GOOGLE_APPLICATION_CREDENTIALS 參數,然後把所有內容貼上環境參數。

image-20240413225710980

  • 接下來會跟大家講,如何修改相關程式碼?
	// Init firebase related variables
	ctx := context.Background()
	opt := option.WithCredentialsJSON([]byte(os.Getenv("GOOGLE_APPLICATION_CREDENTIALS")))
	config := &firebase.Config{DatabaseURL: os.Getenv("FIREBASE_URL")}
	app, err := firebase.NewApp(ctx, config, opt)
	if err != nil {
		log.Fatalf("error initializing app: %v", err)
	}
	client, err := app.Database(ctx)
	if err != nil {
		log.Fatalf("error initializing database: %v", err)
	}
  • 首先option.WithCredentialsJSON([]byte(os.Getenv("GOOGLE_APPLICATION_CREDENTIALS"))) 可以讓你從環境參數讀取到 credential 。
  • 接下來 &firebase.Config{DatabaseURL: os.Getenv("FIREBASE_URL")} 則是將 FIREBASE_URL 內容設定好。
  • 這樣就可以正確執行了,接下來要來看相關處理 Gemini 聊天記憶的部分了。

參考文章:

[科技工作講-心得] 在 LINE 的世界裡: Evan Lin 的科技之旅

前言

最近,我有幸受邀參加了一場精彩的Podcast專訪,由科技工作講主辦。在這個以科技職涯和人才發展為主題的節目中,我分享了自己在LINE台灣開發者關係與技術推廣部門的工作經驗,以及對於科技行業的見解。以下是這次專訪的精華,希望能給大家帶來一些啟發。

專訪概覽

  • 專訪時間:4月3日,晚上10點
  • 專訪形式線上直播
  • 單集標題:LINE的主管聊聊他們在做什麼 feat. LINE 台灣開發者關係與技術推廣部門資深經理 Evan Lin
  • 上線時間:4月6日

職涯分享

我的職業旅程從研究所畢業後開始,那時我加入了一家跨國的軟體公司,他們的業務遍及美國和加拿大。隨後,我也在台灣的硬體公司和新創企業中擔任過要職。特別是在新創公司的時光,我非常積極地參與技術分享和開源軟體開發,這讓我有機會接觸到許多新的領域和機會。

這段經歷對我來說是一個轉捩點,因為我在開源軟體開發和技術推廣方面的熱情,恰好與 LINE 當時的職缺非常契合。所以,在2018年底,我決定加入LINE台灣,開始了我在這裡的新篇章。

LINE的工作文化

在 LINE,溝通是我們極為重視的一環。我們不僅透過自家開發的通訊平台進行直接討論,還非常注重開放性和自主性。我們鼓勵員工與上司討論,表達自己對於新專案或新挑戰的意願。這種文化鼓勵我們主動探索和擴展自己的能力範圍。實習生也能夠體驗到這樣的開放文化,這證明了LINE的開放和自主。

部門工作內容

我們的部門負責推廣LINE的開發者生態系統和技術品牌。我們舉辦外部活動和工作坊教學,並且推廣LINE工程團隊的技術分享活動。我們的總公司在日本,提供全球市場的服務,並且在台灣也持續發展在地服務,如LINE TODAY。

img

(關於 LINE 台灣的企業參訪: 詳情請看文章關於 LINE 台灣開發者關係與技術推廣部門的校園相關資源)

工作上的挑戰

img

(在 LINE 研發工程團隊中,我們有相關的文化來塑造團隊合作氛圍,請參考 LINE Engineering Culture)

在LINE,我們鼓勵直接與相關部門的同仁溝通,這種開放的溝通方式大大提高了效率。在這裡,老闆不僅期待你執行既定的任務,他們更希望你能提出新的想法,並且主動去推動讓這些想法成為現實。

資深軟體開發人力市場

資深軟體開發人員的需求一直都很高。在LINE,我們透過舉辦技術研討會和社群聚會來吸引資深人才,並且非常注重人才的培養。我們有「LINE TECH FRESH」的技術新星實習計畫,旨在培養有潛力的軟體開發工程師。

img

(LINE 台灣的開發者技術年會 - LINE TAIWAN TECHPUSE )

加入LINE的建議

對於想要加入LINE的朋友,學歷背景並不是唯一標準。更重要的是你對軟體開發的熱情,你的學習能力和願意深入了解系統架構背後的效能限制。我們鼓勵參與開源專案,這對於開發工作來說是非常重要的。在LINE的實習生中,我們也有來自不同學科的優秀學生,他們的跨領域學習精神和對軟體開發的熱愛,讓他們在實習結束後也獲得了轉為正職的機會。

img

LINE TECH FRESH:培育下一代科技領袖

在我們的專訪中,我提到了「LINE TECH FRESH」計畫,這是LINE台灣為了培養新一代科技人才而特別推出的培育計畫。在這個快速變遷的數位時代,我們深刻理解到,培養年輕學子的重要性。因此,我們致力於幫助參與者建立堅實的技術基礎,同時兼顧軟實力的提升,為未來職涯發展奠定全面的基石。

計畫特色

專業訓練課程

我們提供一系列精心設計的訓練課程,涵蓋最新的技術趨勢與工具。這些課程旨在讓實習生能夠快速適應職場環境,並掌握必要的技術知識。

實務實習機會

實習生將有機會參與實際的專案,並在專業人士的指導下,將所學知識應用於實務工作中。這不僅是一個學習的機會,也是一個證明自己能力的舞台。

跨部門交流

透過與LINE各部門專業人才的交流,實習生將能夠獲得多元化的視角與經驗。這種跨部門的互動對於擴展視野和建立人脈網絡都是非常有價值的。

職涯發展支援

從個人職涯規劃到專業技能提升,我們提供全方位的支援。我們的目標是協助實習生找到最適合自己的職涯道路,並在科技領域中脫穎而出。

轉正機會

表現優異的實習生將有機會在計畫結束後,成為LINE台灣的正式員工。這是一個讓實習生能夠持續在LINE這個大家庭中成長的機會。

更多細節請參考: LINE TECH FRESH 2024 Summer Class 招募相關說明 (時程, 職缺)

活動小結

「LINE TECH FRESH」計畫是我們對於人才培養的承諾,也是LINE文化的一部分。我們相信,透過這個計畫,我們不僅能夠吸引優秀的開發人才,更能為台灣的資深軟體開發人力市場做出貢獻。

立即加入「LINE 開發者官方社群」官方帳號,就能收到第一手 Meetup 活動,或與開發者計畫有關的最新消息的推播通知。▼

「LINE 開發者官方社群」官方帳號 ID:@line_tw_dev

img

關於「LINE 開發社群計畫」

LINE 於 2019 年開始在台灣啟動「LINE 開發社群計畫」,將長期投入人力與資源在台灣舉辦對內對外、線上線下的開發者社群聚會、徵才日、開發者大會等,已經舉辦 30 場以上的活動。歡迎讀者們能夠持續回來查看最新的狀況。詳情請看:

[LINE Bot][Python] Cloud Function + Gemini Pro + Firebase Database = 記憶體聊天機器人

image-20240318204441270

起因

這邊文章,主要是透過【LineBot實作】如何製作有記憶的對話機器人 的相關修改。 把需要付費的服務 OpenAI 改成目前還有免費額度的 Google Gemini ,並且針對相關訊息的程式碼做一些調整。 主要的 LINe Bot 設定與 Firebase 設定請參考原先文章。

快速講解一下設定的方法:

這裡僅快速條列式,講解一下該如何設定這個應用。

  • 建立 LINE Bot 帳號
    • 首先先去 LINE Developer Console 建立一個 Messaging API Channel
    • 在 Basic Setting Tab 取得 Channel secret
    • 在 Messaging API Tab 產生 (issue) Channel access token
  • 到 Google Cloud 的 Firebase
    • 建立一個專案
    • 設定一個 Realtime Database
    • 更改安全規則,讓資料庫可以被任何人存取與修改。(請注意: 這是因為做測試專案,請勿再正式專案如此設定)
    • 取得該資料庫網址: https://XXX.firebaseio.com/
  • 到 Google Cloud 的 Cloud Functions
    • 建立一個 Cloud Functions - Gen1 或是 Gen2 都可以
    • 採取 HTTPS
    • 驗證部分: 使用「允許未經驗證的叫用」
    • 新增四個環境變數
      1. GEMINI_API_KEY:(在 Google AI Studio 獲得的secret key)
      2. LINE_BOT_TOKEN:(在Line Developers獲得的Channel access token)
      3. LINE_BOT_SECRET:(在Line Developers獲得的Channel secret)
      4. FIREBASE_URL:(在Firebase獲得的URL)
    • 程式碼部分,請使用以下修改的程式碼。

主要修改程式碼部分

首先是 requirements.txt 需要將相關設備改成 Gemini pro - google.generativeai

接下來建立另外一個檔案: main.py

設定 “進入點” 到 linebot,並且記錄觸發網址 https://xxxxxxxx.cloudfunctions.net/function-test1

關於 OpenAI ChatComplete 與 Google Gemini Pro - Multi-turn conversations 格式轉換

這邊講解一下,關於 OpenAI 的 Chat Completion API 的格式:

[
  {
    "role": "system",
    "content": "You are a helpful assistant."
  },
  {
    "role": "user",
    "content": "Hello!"
  }
]

但是 Google Gemini Pro 的 Multi-turn Conversations 格式不太一樣。

[
    {'role':'user',
     'parts': ["Briefly explain how a computer works to a young child."]},
    {'role':'model',
     'parts': ["想像一下你的電腦就像一個超級聰明的機器人,它可以按照你的指令去做很多事情....."]}   
]

主要差別除了 “content” 與 “parts” 命名不同外, parts 可以接受多種資料格式。可以參考 API Reference 關於 Gemini Content

回頭設定 LINE Bot

  • 設定 LINE Developer Console 到了 Messaging API Tab 並且將 Webhook URL 放入剛剛輸入的 https://xxxxxxxx.cloudfunctions.net/function-test1
  • 測試是否成功,即可開始對聊天機器人溝通。

參考文章:

[LINEBot SDK][Python] 使用 AiohttpAsyncHttpClient 處理 LINE Bot 圖片消息

使用 AiohttpAsyncHttpClient 處理 LINE Bot 圖片消息

在開發 LINE Bot 應用時,我遇到了一個挑戰:如何有效地處理用戶發送的圖片消息。我需要從 LINE 平台獲取圖片內容,然後將其用於後續的處理。這裡,我想分享我的問題與解決方式,特別是在使用 AiohttpAsyncHttpClient 與普通 HTTP 客戶端之間的比較。

套件: https://github.com/line/line-bot-sdk-python

問題描述

當用戶通過 LINE Bot 發送圖片時,我需要從 LINE 的服務器上獲取圖片數據。初始的問題出現在嘗試使用一個不存在的 iter_any 方法來讀取數據流,這導致了一個 AttributeError。這個問題很快被發現並修正,但我還想探索一種更高效的方法來處理這些圖片數據。

以前做法

這是以前透過 non-async 的做法,資料會完整讀完才會繼續執行。

ef handle_message(event):
	if (event.message.type == "image"):
		SendImage = line_bot_api.get_message_content(event.message.id)

		local_save = './static/' + event.message.id + '.png'
		with open(local_save, 'wb') as fd:
			for chenk in SendImage.iter_content():
				fd.write(chenk)
                
		line_bot_api.reply_message(event.reply_token, ImageSendMessage(original_content_url = ngrok_url + "/static/" + event.message.id + ".png", preview_image_url = ngrok_url + "/static/" + event.message.id + ".png"))

這樣有可能會在某些地方卡住很久,造成整個流程無法繼續進行。

AiohttpAsyncHttpClient 的優勢

AiohttpAsyncHttpClientline-bot-sdk 的一部分,它提供了一種非同步的方式來處理 HTTP 請求。這與傳統的同步 HTTP 客戶端有著本質的不同。在同步模式下,每個 HTTP 請求都會阻塞當前執行線程,直到收到響應。這在處理大量請求或需要高性能的應用中是不可取的。

相反,AiohttpAsyncHttpClient 允許我們發送非同步請求,這意味著我們可以在等待響應的同時繼續執行其他代碼。這對於提高應用的響應性和吞吐量至關重要。

from linebot.aiohttp_async_http_client import AiohttpAsyncHttpClient

.....

async_http_client = AiohttpAsyncHttpClient(session)
line_bot_api = AsyncLineBotApi(channel_access_token, async_http_client)

解決方案

我採用了以下代碼來異步獲取圖片內容:

message_content = await line_bot_api.get_message_content(event.message.id)
image_content = b''
async for s in message_content.iter_content():
    image_content += s
img = PIL.Image.open(BytesIO(image_content))

這段代碼使用 AiohttpAsyncHttpClient 通過 line_bot_api.get_message_content 異步獲取消息內容。然後,我使用 iter_content 方法來異步迭代數據塊,並將它們合併到一個二進制字符串中。最後,我使用 PIL.Image.open 從這個二進制數據創建了一個圖片對象。

這種方法的好處是,它完全非阻塞。即使在下載大圖片時,我們的應用也可以繼續處理其他事件或消息,從而提高了整體效率。

結論

通過使用 AiohttpAsyncHttpClient,我成功地解決了處理 LINE Bot 圖片消息的問題,並且提高了應用的性能。這個案例展示了異步編程在現代應用開發中的重要性,特別是在需要處理大量 I/O 操作時。對於開發者來說,理解並利用這些異步工具將是提高應用性能和用戶體驗的關鍵。

參考文章: