louis2557
commented
10 months ago this is my crd config
Upstream config
Namespace: staging
Labels: <none>
Annotations: <none>
API Version: apisix.apache.org/v2
Kind: ApisixUpstream
Metadata:
Creation Timestamp: 2023-12-20T09:41:45Z
Generation: 1
Managed Fields:
API Version: apisix.apache.org/v2
Fields Type: FieldsV1
fieldsV1:
f:spec:
f:discovery:
f:serviceName:
f:type:
f:subsets:
Manager: Terraform
Operation: Apply
Time: 2023-12-20T09:41:45Z
API Version: apisix.apache.org/v2
Fields Type: FieldsV1
fieldsV1:
f:status:
.:
f:conditions:
Manager: apisix-ingress-controller
Operation: Update
Subresource: status
Time: 2023-12-20T09:41:45Z
Resource Version: 1096002412
UID: 0a11cfdf-9c9c-4677-8094-5699bac81f5b
Spec:
Discovery:
Service Name: staging/moovshop-api-writer-svc:http
Type: kubernetes
Subsets:
Labels:
Version: add-cart
Name: add-cart
Labels:
Version: active-cart
Name: active-cartRoute config
Namespace: staging
Labels: <none>
Annotations: <none>
API Version: apisix.apache.org/v2
Kind: ApisixRoute
Metadata:
Creation Timestamp: 2023-12-20T09:41:50Z
Generation: 1
Managed Fields:
API Version: apisix.apache.org/v2
Fields Type: FieldsV1
fieldsV1:
f:spec:
f:http:
Manager: Terraform
Operation: Apply
Time: 2023-12-20T09:41:50Z
API Version: apisix.apache.org/v2
Fields Type: FieldsV1
fieldsV1:
f:status:
.:
f:conditions:
Manager: apisix-ingress-controller
Operation: Update
Subresource: status
Time: 2023-12-20T09:41:50Z
Resource Version: 1096002517
UID: dad3cd39-a116-46f8-bef1-6007fa0e2245
Spec:
Http:
Backends:
Resolve Granularity: service
Service Name: moovshop-api-writer-svc
Service Port: 80
Subset: add-cart
Match:
Hosts:
uat-api.moovshop.com
Paths:
/api/cart/item/add
Name: add-cart
Plugins:
Config:
allow_credential: true
allow_headers: X-Forwarded-For,DNT,X-CustomHeader,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Authorization,X-Page-Token,Access-Control-Allow-Origin
allow_methods: GET,POST,PUT,DELETE,PATCH,HEAD,OPTION,CONNECT,TRACE,PURGE
allow_origins: https://uat.moovshop.com
expose_headers: X-Forwarded-For,DNT,X-CustomHeader,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Authorization,X-Page-Token,Access-Control-Allow-Origin
Enable: true
Name: cors
Config:
Functions:
return function(conf, ctx)
function string.starts(String, Start)
return string.sub(String,1,string.len(Start))==Start
end
-- Import neccessary libraries
local http = require("resty.http")
local core = require("apisix.core")
local path = ctx.curr_req_matched._path
local checkDatetime = "true"
if string.starts(path, "/api") and path ~= "/api/login" and string.starts(path, "/api/admin") ~= true then
local pageToken = core.request.header(ctx, "X-Page-Token")
local clientIp = core.request.header(ctx, "X-Forwarded-For")
if not pageToken or pageToken == "" then
core.response.exit(403, { error_msg = "pageToken is invalid" })
end
if not clientIp or clientIp == "" then
core.response.exit(403, { error_msg = "clientIp is invalid" })
end
core.log.info(core.request.headers(ctx))
core.log.info("check token: " .. pageToken .. ", client Ip: " .. clientIp)
-- Send request to extract page token
local httpc = http.new()
local res, err = httpc:request_uri("http://moovshop-extract-token.staging.svc.cluster.local", {
method = "GET",
path = "/getPageTokenPayload?clientIp=" .. clientIp .. "&checkDatetime=" .. checkDatetime,
headers = {
["X-Page-Token"] = pageToken
},
})
if not res then
core.response.exit(403, { error_msg = "extract page token failed" })
end
if res.status ~= 200 then
core.response.exit(403, { error_msg = "extract token failed, code: " .. res.status .. ", reason: " .. res.reason .. ", clientIp: " .. clientIp })
else
local sessionId = string.sub(res.body, 2, -2)
core.log.info("session id from extract token: " .. sessionId)
core.request.add_header(ctx, "X-Session-Id", sessionId)
core.request.set_header(ctx, "X-Page-Token", "")
end
end
end
Enable: true
Name: serverless-pre-function
Backends:
Resolve Granularity: service
Service Name: moovshop-api-writer-svc
Service Port: 80
Subset: active-cart
Match:
Hosts:
uat-api.moovshop.com
Paths:
/api/cart/active
Name: active-cart
Plugins:
Config:
allow_credential: true
allow_headers: X-Forwarded-For,DNT,X-CustomHeader,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Authorization,X-Page-Token,Access-Control-Allow-Origin
allow_methods: GET,POST,PUT,DELETE,PATCH,HEAD,OPTION,CONNECT,TRACE,PURGE
allow_origins: https://uat.moovshop.com
expose_headers: X-Forwarded-For,DNT,X-CustomHeader,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type,Authorization,X-Page-Token,Access-Control-Allow-Origin
Enable: true
Name: cors
Config:
Functions:
return function(conf, ctx)
function string.starts(String, Start)
return string.sub(String,1,string.len(Start))==Start
end
-- Import neccessary libraries
local http = require("resty.http")
local core = require("apisix.core")
local path = ctx.curr_req_matched._path
local checkDatetime = "true"
if string.starts(path, "/api") and path ~= "/api/login" and string.starts(path, "/api/admin") ~= true then
local pageToken = core.request.header(ctx, "X-Page-Token")
local clientIp = core.request.header(ctx, "X-Forwarded-For")
if not pageToken or pageToken == "" then
core.response.exit(403, { error_msg = "pageToken is invalid" })
end
if not clientIp or clientIp == "" then
core.response.exit(403, { error_msg = "clientIp is invalid" })
end
core.log.info(core.request.headers(ctx))
core.log.info("check token: " .. pageToken .. ", client Ip: " .. clientIp)
-- Send request to extract page token
local httpc = http.new()
local res, err = httpc:request_uri("http://moovshop-extract-token.staging.svc.cluster.local", {
method = "GET",
path = "/getPageTokenPayload?clientIp=" .. clientIp .. "&checkDatetime=" .. checkDatetime,
headers = {
["X-Page-Token"] = pageToken
},
})
if not res then
core.response.exit(403, { error_msg = "extract page token failed" })
end
if res.status ~= 200 then
core.response.exit(403, { error_msg = "extract token failed, code: " .. res.status .. ", reason: " .. res.reason .. ", clientIp: " .. clientIp })
else
local sessionId = string.sub(res.body, 2, -2)
core.log.info("session id from extract token: " .. sessionId)
core.request.add_header(ctx, "X-Session-Id", sessionId)
core.request.set_header(ctx, "X-Page-Token", "")
end
end
end
Enable: true
Name: serverless-pre-function
Revolyssup
github-actions[bot]
Current Behavior
Hi, I used k8s crd to create apisixroute and apisixupstream, I also add subset and subsets config to both, but the taffic can't be routed to appropriate pods which contain corresponding labels
Expected Behavior
the route traffic can be routed to appropriate pods which contain corresponding labels
Error Logs
2023-12-27T14:50:01+08:00 error apisix/apisix_upstream.go:236 failed to get service staging/moovshop-cms-api-upstream: service "moovshop-cms-api-upstream" not found 2023-12-27T14:50:01+08:00 info apisix/apisix_upstream.go:481 sync ApisixUpstream but not found, ignore {"event_type": "sync", "ApisixUpstream": {"Key":"staging/moovshop-cms-api-upstream","OldObject":null,"GroupVersion":"apisix.apache.org/v2"}}Steps to Reproduce