
在 Kong 的自訂套件開發中,handler.lua 和 schema.lua 是兩個核心檔案,負責定義套件的邏輯行為與設定結構。
-- 導入必要的 Kong 模組
local kong_meta = require "kong.meta"
local cjson = require "cjson.safe"
-- 定義套件的基本資訊
-- PRIORITY: 執行優先級,數字越大優先級越高
-- VERSION: 套件版本號
local CustomHandler = {
PRIORITY = 990,
VERSION = "1.0",
}
-- 套件的主要處理函數
-- 在 access 階段執行,用於處理請求前的邏輯
function CustomHandler:access(plugin_conf)
kong.log(">>>>>>>> 套件開始執行 <<<<<<<<")
-- 從套件配置中提取參數
kong.log(">>>>>>>>> 步驟1: 載入配置參數 <<<<<<<<<")
local METHOD = plugin_conf.method
local HEADERS = plugin_conf.headers
local BODY = plugin_conf.body
kong.log(">>>>>>>>> 配置載入完成 <<<<<<<<<")
-- 記錄配置資訊到日誌
kong.log(">>>>>>>>> 步驟2: 記錄配置資訊 <<<<<<<<<")
kong.log(">>>>>>>>> 請求方法 = ", cjson.encode(METHOD), "<<<<<<<<<")
kong.log(">>>>>>>>> 請求頭部 = ", cjson.encode(HEADERS), "<<<<<<<<<")
kong.log(">>>>>>>>> 請求體 = ", cjson.encode(BODY), "<<<<<<<<<")
kong.log(">>>>>>>>> 配置記錄完成 <<<<<<<<<")
-- access 階段不需要返回值,請求會繼續向下處理
-- 如果需要修改請求,可以在這裡設定 header 或其他屬性
end
return CustomHandler
local typedefs = require "kong.db.schema.typedefs"
return {
name = "log-traffic",
fields = {
{ protocols = typedefs.protocols_http },
{ config = {
type = "record",
-- 此處根據 handler.lua 檔案中的配置,來新增指定欄位
fields = {
{ method = { type = "string", default = "GET"} },
{ headers = {
type = "map",
keys = typedefs.header_name {
match_none = {
{
pattern = "^[Hh][Oo][Ss][Tt]$",
err = "cannot contain 'Host' header",
},
{
pattern = "^[Cc][Oo][Nn][Tt][Ee][Nn][Tt]%-[Ll][Ee][nn][Gg][Tt][Hh]$",
err = "cannot contain 'Content-Length' header",
},
},
},
values = {
type = "string",
referenceable = true,
},
}},
{ body = {
type = "map",
keys = {
type = "string",
referenceable = true,
},
values = {
type = "string",
referenceable = true,
},
}},
},
},
},
},
}
P.S. vs code emmyLua 可以加速開發
Kong 官方建議將自訂 Plugin 放在 Kong 的 Lua 路徑下,或是 Docker 映像檔的 /usr/local/share/lua/5.1/kong/plugins/ 目錄。不過,在開發階段,放在專案資料夾內管理即可,部署時再複製到正確位置或用 Docker volume 掛載。
docker cp log-traffic kong:/usr/local/share/lua/5.1/kong/plugins
docker exec -it -u root kong /bin/sh
apt update && apt install -y vim
vim /usr/local/share/lua/5.1/kong/constants.lua
在 plugin 清單裡加上自己的套件名稱 "log-traffic"
| 檔案位置 | 說明 |
|---|---|
/etc/kong/kong.conf.default | 預設範本,不能直接修改 |
/etc/kong/kong.conf | 正式用的設定檔(自己從 default 複製來的) |
新建/修改 /etc/kong/kong.conf:
vim /etc/kong/kong.conf
加入以下設定:
plugins = bundled,log-traffic # 指定了要載入的套件 # lua_package_path = /kong/plugins/?.lua;; # 指定了自訂套件的目錄
docker restart kong
重啟後,檢查客製的套件是不是有在支援清單中:
http://localhost:8001/plugins/enabled
套用到服務:
POST http://localhost:8001/services/{service}/plugins
Content-Type: application/json
{
"name": "log-traffic"
}
套用到路由:
POST http://localhost:8001/routes/{route}/plugins
Content-Type: application/json
{
"name": "log-traffic"
}
查看已套用的套件:http://localhost:8001/plugins/
查看 Docker 日誌來確認套件是否正常運作:
docker logs kong
Kong 本身不支援 Lua Plugin 的熱重載,每次修改 Plugin 內容後都需要重啟 Kong 容器。開發時建議:
kong.log.inspect() 可以更方便地輸出 table 結構,便於除錯。print(),但建議還是用 kong.log 相關 API,這樣 log 會出現在 Kong 的標準日誌中。範例:
kong.log.inspect(plugin_conf)
Kong Plugin 支援多個執行階段(phase),常見有:
access:處理請求前header_filter:處理回應 headerbody_filter:處理回應 bodylog:請求結束後你可以根據需求實作不同階段的函數,例如:
function CustomHandler:header_filter(conf)
kong.response.set_header("X-My-Plugin", "active")
end
如果 plugin 需要存取資料庫,可以使用 Kong 提供的 DAO(Data Access Object)API,例如存取 Postgres:
local dao = kong.db.your_custom_table
local row, err = dao:select({ id = some_id })
可以用 Lua 的 http client(如 resty.http)在 plugin 內呼叫外部 API:
local http = require "resty.http"
local httpc = http.new()
local res, err = httpc:request_uri("https://api.example.com", { method = "GET" })
host = os.getenv("KONG_PG_HOST") or "192.168.201.101",
return {
host = os.getenv("KONG_PG_HOST") or "192.168.201.101",
port = tonumber(os.getenv("KONG_PG_PORT")) or 5432,
database = os.getenv("KONG_PG_DATABASE") or "kong",
user = os.getenv("KONG_PG_USER") or "kong",
password = os.getenv("KONG_PG_PASSWORD") or "kong",
pool_size = 10,
pool_name = "custom_acl_pool"
}
在 Lua(包括 Kong 插件開發)中,pcall(function) 是「protected call」的縮寫,用來安全執行一段可能會出錯的程式碼,避免錯誤直接中斷整個請求流程。
主要用途 捕捉執行時錯誤:如果 function 內部有錯誤(例如資料庫連線失敗、語法錯誤等),pcall 會捕捉這個錯誤,不會讓 Lua 腳本直接崩潰。 回傳錯誤資訊:pcall 會回傳兩個值:success(布林值,表示有無錯誤)和 result(成功時是回傳值,失敗時是錯誤訊息)。 範例
Q: Plugin 沒有生效怎麼辦?
A:
/usr/local/share/lua/5.1/kong/plugins/ 目錄/etc/kong/kong.conf 是否有加到 plugins 列表Q: 如何管理多個自訂 Plugin?
A: