使用 Istio EnvoyFilter 检查标头是否包含有效令牌

我需要验证是否提供了正确值的自定义标头。如果没有,则要拒绝访问该服务并生成带有消息的 401。

我已经能够为此创建 Istio AuthorizationPolicy,但它会给我 403,这并不完全正确,但我想要正确并给予 401。

到目前为止,这是我尝试的内容,不幸的是它对我发送的请求没有任何影响(我不是 envoy 或 lua 专家,请您谅解):

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  name: custom-filter
  namespace: dev
spec:
  workloadSelector:
    labels:
      istio: ingressgateway
  configPatches:
  - applyTo: NETWORK_FILTER # http connection manager 表示 Envoy 中的一个过滤器
    match:
      context: GATEWAY
      listener:
        filterChain:
          filter:
            name: "envoy.http_connection_manager"
    patch:
      operation: MERGE
      value: # lua 过滤器规范
        name: envoy.lua
        typed_config:
          "@type": "type.googleapis.com/envoy.config.filter.http.lua.v2.Lua"
          inlineCode: |
            function envoy_on_request(request_handle)
              if request_handle:headers():get("auth_token") != "xxx" then
                request_handle:respond({[":status"] = "401"}, "nope")
              end
            end

会产生 403 并且我希望用上面的方法替换的工作 AuthorizationPolicy:

apiVersion: security.istio.io/v1beta1
kind: AuthorizationPolicy
metadata:
  name: deny-method-get
  namespace: dev
spec:
  selector:
    matchLabels:
      app: myapp
  action: DENY
  rules:
  - when:
    - key: request.headers[auth_token]
      notValues: ["xxx"]
点赞
用户10020419
用户10020419

根据我理解,istio 的响应是正确的:

根据 RFC 标准:

401(未经授权)状态代码表示请求未被应用,因为它缺少目标资源的有效身份验证凭据……用户代理可以使用新的或替换的授权标头字段重复该请求。

403(禁止)状态代码表示服务器理解请求,但拒绝授权……如果请求中提供了身份验证凭据,则服务器认为它们不足以授权访问。

因此,您携带令牌的请求已被理解但被禁止(403),而没有令牌的请求根本没有提供凭据,因此是未经授权的。

关于你的过滤器:

将过滤器应用于 HTTP_FILTER 而不是 NETWORK_FILTER。并且应该在任何其他过滤器之前应用,所以将操作设置为 INSERT_BEFORE

更新

要将过滤器应用于单个 Pod 而不是所有 Pod,请将上下文从 GATEWAY 更改为 SIDECAR_INBOUND,然后设置 workloadSelector

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  name: custom-filter
  namespace: dev
spec:
  workloadSelector:
    labels:
      app: my-app
  configPatches:
  - applyTo: HTTP_FILTER
    match:
      context: SIDECAR_INBOUND
      listener:
        filterChain:
          filter:
            name: "envoy.http_connection_manager"
            subFilter:
              name: "envoy.router"
    patch:
      operation: INSERT_BEFORE
      value: # lua filter specification
        name: envoy.lua
        typed_config:
          "@type": "type.googleapis.com/envoy.config.filter.http.lua.v2.Lua"
          inlineCode: |
            function envoy_on_request(request_handle)
              if request_handle:headers():get("auth_token") ~= "my_secret_token" then
                request_handle:respond({[":status"] = "401"}, "nope")
              end
            end

2020-08-25 12:02:10