文档中心

			

				{
			

			

				 "cache_time":10, // 认证结果缓存时间，单位秒，合法值：0 ~ 3600 秒
			

			

				 "endpoint_timeout":15, // 后端超时时间，单位秒，合法值：0 ~ 60 秒
			

			

				 "func_name":"test_name", // 自定义函数名称
			

			

				 "func_namespace":"test_namespace", // 自定义函数命名空间
			

			

				 "func_qualifier":"$LATEST", // 自定义函数版本
			

			

				 "is_send_body":true, // 是否将请求Body发送到函数
			

			

				 "header_auth_parameters":[ // Header位置的认证参数，插件根据参数值来缓存认证结果
			

			

				 "Header1"
			

			

				 ],
			

			

				 "query_auth_parameters":[ // Query位置的认证参数，插件根据参数值来缓存认证结果
			

			

				 "Query1"
			

			

				 ],
			

			

				 "user_id":1253970226, // appid
			

			

				 "version":"2021-12-26 17:17:49" 
			

			

				 // 插件版本，格式：yyyy-MM-dd HH:mm:ss，编辑插件时，传入新值会使得插件下的缓存结果失效
			

			

				}
			

			

				{ "requestContext": { // 请求的信息 "path": "\/test", "httpMethod": "POST", "sourceIp":
			

			

				 "113.108.77.64", "stage": "release", "serviceId": "service-i76yjnfu", "identity": {} },
			

			

				 "path": "\/test", // 请求路径 "httpMethod": "POST", // 请求方法 "body": "{\"data\":1}", 
			

			

				// 请求Body "queryStringParameters": { // 请求的Query "query": "1"}, "headerParameters": 
			

			

				{ // 请求Header "accept": "*\/*", "host": "service-ixxxxx-xxxxx.gz.tencentapigw.cn", 
			

			

				"header-auth": "apigw", "content-length": "10", "content-type": "application\
			

			

				/x-www-form-urlencoded", "user-agent": "curl\/8.1.2" } 
			

			

				{
   "api-auth": true,                     // 认证结果 true:认证通过  false:认证失败
   "api-succ-headers": {"key":"value"},  // 认证成功后需要添加到转发到后端的header 
   "api-response": "auth fail"           // 认证失败后返回自定义内容
}
			

			

				from http.server import BaseHTTPRequestHandler, HTTPServer from urllib.parse import urlparse, parse_qs import json 
				

					PORT_NUMBER = 8088 class MyHandler(BaseHTTPRequestHandler): def do_POST(self): response = {'api-auth': True} #
				

				

					 Header认证 header_auth_key = self.headers.get("header-auth") if header_auth_key == "apigw": response
				

				

					['api-auth'] = False # Query认证 # parsed_url = urlparse(self.path) # query_params
				

				

					 = parse_qs(parsed_url.query) # query_auth_key = query_params.get("query-auth",
				

				

					 [None])[0] #if query_auth_key == "apigw": #    response['api-auth'] = False 
				

				

					self.send_response(200) self.send_header('Content-type', 'application/json') 
				

				

					self.end_headers() self.wfile.write(json.dumps(response).encode('utf-8')) try:
				

				

					 server = HTTPServer(('', PORT_NUMBER), MyHandler) print(f'Started HTTP server
				

				

					 on port {PORT_NUMBER}') # Wait forever for incoming HTTP requests server.serve_f
				

				

					orever() except KeyboardInterrupt: print('^C received, shutting down the web server')
				

				

					 server.socket.close()
				

			

			

				from http.server import BaseHTTPRequestHandler, HTTPServer import json 
				

					PORT_NUMBER = 8088 class MyHandler(BaseHTTPRequestHandler): def do_POST(self): 
				

				

					response = {'api-auth': True} content_length = int(self.headers.get('Content-Length',
				

				

					 0)) request_body = self.rfile.read(content_length).decode('utf-8') request_body = 
				

				

					json.loads(request_body) # Header认证 header_parameters = request_body.get('headerPar
				

				

					ameters', {}) if header_parameters.get('header-auth') == "apigw": response['api-auth']
				

				

					 = False # Query认证 # query_parameters = request_body.get('queryStringParameters',
				

				

					 {}) # if query_parameters.get('query-auth') == "apigw": #     response['api-auth'] 
				

				

					= False self.send_response(200) self.send_header('Content-type', 'application/json') 
				

				

					self.end_headers() self.wfile.write(json.dumps(response).encode('utf-8')) try: serve
				

				

					r = HTTPServer(('', PORT_NUMBER), MyHandler) print(f'Started HTTP server on port 
				

				

					{PORT_NUMBER}') # Wait forever for incoming HTTP requests server.serve_forever() 
				

				

					except KeyboardInterrupt: print('^C received, shutting down the web server') 
				

				

					server.socket.close()