该envoyfilter实现了这样一个功能,如果请求头中含有Sw8,则添加请求头HasSw8: true。
1. 内嵌lua脚本
apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:name: add-header-filternamespace: demo-bookinfo # 可根据实际情况调整命名空间
spec:workloadSelector:# 应用到的工作负载,若要应用到所有工作负载,可省略 workloadSelectorlabels:app: serviceaconfigPatches:- applyTo: HTTP_FILTERmatch:context: SIDECAR_INBOUND # 应用到入方向流量proxy:proxyVersion: '^1\.19.*' # 匹配特定版本的 Istiolistener:filterChain:filter:name: "envoy.filters.network.http_connection_manager"subFilter:name: "envoy.filters.http.router"patch:operation: INSERT_BEFOREvalue:name: envoy.filters.http.luatyped_config:"@type": "type.googleapis.com/envoy.extensions.filters.http.lua.v3.Lua"inlineCode: |function envoy_on_request(request_handle)request_handle:headers():add("Example-Header", "default-value")local sw8_header = request_handle:headers():get("Sw8")if sw8_header thenrequest_handle:headers():add("HasSw8", "true")endend
2. 引入外部文件
先将lua脚本文件放到istio-proxy容器指定目录下(可以通过configmap)。
lua
-- 文件路径: /etc/envoy/lua/add_header.luafunction envoy_on_request(request_handle)-- 添加一个默认的 header,例如 Example-Header: default-valuerequest_handle:headers():add("Example-Header", "default-value")-- 检查是否存在 Sw8 headerlocal sw8_header = request_handle:headers():get("Sw8")if sw8_header then-- 如果存在 Sw8,添加 HasSw8: truerequest_handle:headers():add("HasSw8", "true")end
end
envoyfilter:
apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:name: lua-header-filternamespace: demo-bookinfo
spec:workloadSelector:labels:app: serviceaconfigPatches:- applyTo: HTTP_FILTERmatch:context: SIDECAR_INBOUND # 流量方向:入方向listener:filterChain:filter:name: "envoy.filters.network.http_connection_manager"subFilter:name: "envoy.filters.http.router"patch:operation: INSERT_BEFOREvalue:name: envoy.filters.http.luatyped_config:"@type": type.googleapis.com/envoy.extensions.filters.http.lua.v3.Luainline_code: |-- 加载外部 Lua 文件local lua_script = assert(loadfile("/var/lua/add_header.lua"))lua_script()