特使过滤器拦截上游响应

Question

我已经为 Envoy 编写了 ext_authz 过滤器，并且对 Envoy 过滤器的工作原理有基本的了解。但现在我想过滤从上游返回的响应。具体来说，我想处理两件事：

拦截来自上游的 data/jsonBody 和 Filter/Modify 在 envoy 发送回下游之前基于一些业务规则的 responseJsonBody。
如果上游关闭（当 http 响应代码 408-Timeout 时），我想将 post-请求保存到 async-msg-que 并发回 202-Accepted到下游。这样，当上游返回时，它将处理来自它的 async-msg-que.
的未决 post-请求

是否有我可以用于这些目的的现有过滤器，或者使用 envoy-proxy sidecar 执行此操作的正确方法是什么。

谢谢。

Answer 1

您需要使用 lua 自己编写过滤器：

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  name: custom-filter
  namespace: some-namespace
spec:
  workloadSelector:
    labels:
      istio: ingressgateway
  configPatches:
  - applyTo: HTTP_FILTER
    match:
      context: GATEWAY
      listener:
        filterChain:
          filter:
            name: "envoy.filters.network.http_connection_manager"
            subFilter:
              name: "envoy.extAuthz" # name of your ext_authz filter
    patch:
      operation: INSERT_AFTER
      value: 
       name: envoy.custom-resp
       typed_config:
          "@type": "type.googleapis.com/envoy.extensions.filters.http.lua.v3.Lua"
          inlineCode: |
            function envoy_on_response(response_handle) 
              if response_handle:headers():get(":status") == "408" then
                -- send message depending on your queue, eg via httpCall()
                -- Overwrite status and body
                response_handle:headers():replace(":status", "202")
              else 
                -- get response body as jsonString
                local body = response_handle:body()
                local jsonString = tostring(body:getBytes(0, body:length()))
                -- do something, eg replace secret by regex 
                jsonString = jsonString:gsub("(foo|bar)", "")
                response_handle:body():set(jsonString)
              end
            end

请注意，您需要以某种方式处理队列超时。

Envoy With Lua

httpCall

Lua Docs

特使过滤器拦截上游响应

envoy filter to intercept upstream response

istio

envoyproxy

istio-sidecar