Alibaba Cloud API 서명 문제 해결을 통한 청구 분석 구현¶

http://ecs.aliyuncs.com/?SignatureVersion=1.0&Format=JSON&Timestamp=2017-08-07T05%3A50%3A57Z&RegionId=cn-hongkong&AccessKeyId=xxxxxxxxx&SignatureMethod=HMAC-SHA1&Version=2017-12-14&Signature=%2FeGgFfxxxxxtZ2w1FLt8%3D&Action=DescribeSnapshots&SignatureNonce=b5046ef2-7b2b-11e7-a3c5-00163e001831&ZoneId=cn-hongkong-b

SignatureVersion # 서명 알고리즘 버전, 현재 1.0
Format # 응답 메시지 형식, JSON 또는 XML, 기본값은 XML
Timestamp # 요청 타임스탬프, UTC 시간, 예: 2021-12-16T12:00:00Z
AccessKeyId # 계정 키 ID
SignatureMethod # 서명 방식, 현재 HMAC-SHA1
Version # 버전 번호, 날짜 형식, 예: 2017-12-14, 제품마다 다름
Signature # 가장 까다로운 서명
SignatureNonce # 고유 난수, 네트워크 공격 방지. 요청 간에 서로 다른 난수 사용

D = {
    'BillingCycle':str(time.strftime("%Y-%m", time.gmtime())),
    'Action':'QuerySettleBill',
    # 'PageNum':'5',
    'Format':'JSON',
    'Version':'2017-12-14',
    'AccessKeyId':'LTAI5tLumx55Vui4WJwZJneK',
    'SignatureMethod':'HMAC-SHA1',
    'MaxResults' : '300',
    # 'NextToken':"", #?
    'Timestamp':str(time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())),
    'SignatureVersion':'1.0'
    # 'SignatureNonce':str_seed
}

  # 서명은 순서를 포함한 고유성을 요구하므로 매개변수 이름별로 정렬
        sortedD = sorted(D.items(),key=lambda x: x[0])

# Python의 urllib 라이브러리를 사용하여 인코딩
def percentEncode(str):
    res = urllib.parse.quote(str.encode('utf8'), '')
    res = res.replace('+', '%20')
    res = res.replace('*', '%2A')
    res = res.replace('%7E', '~')
    return res

# 표준화된 요청 문자열 생성
canstring = ''
for k,v in sortedD:
    canstring += '&' + percentEncode(k) + '=' + percentEncode(v)

        # 표준화된 요청 문자열 생성
        stringToSign = 'GET&%2F&' + percentEncode(canstring[1:])

# access_key_secret
access_key_secret = '<access_key_secret>'
# HMAC 값 계산
h = hmac.new((access_key_secret + "&").encode('utf8'), stringToSign.encode('utf8'), sha1)

# 서명 값 계산하여 signature 서명 생성
signature = base64.encodestring(h.digest()).strip()

# 서명 추가
D['Signature'] = signature

# 최종 API 호출
url = 'http://business.aliyuncs.com/?' + urllib.parse.urlencode(D)
http://business.aliyuncs.com/?BillingCycle=2021-12&Action=QuerySettleBill&Format=JSON&Version=2017-12-14&AccessKeyId=LTAI5tLumx55Vui4WJwZJneK&SignatureMethod=HMAC-SHA1&MaxResults=300&Timestamp=2021-12-16T12%3A27%3A58Z&SignatureVersion=1.0&SignatureNonce=0.30196531140307337&NextToken=&Signature=zFb4631sSGONvAeWD3xCIovMeoM%3D

import sys, datetime
import time
import json
import urllib
import hmac
from hashlib import sha1
import base64
import random
import requests


# 요청에 필요한 공통 매개변수(API 호출 시 항상 필요한 매개변수)
D = {
    'BillingCycle':str(time.strftime("%Y-%m", time.gmtime())),
    'Action':'QuerySettleBill',
    # 'PageNum':'5',
    'Format':'JSON',
    'Version':'2017-12-14',
    'AccessKeyId':'<AccessKeyId>',
    'SignatureMethod':'HMAC-SHA1',
    'MaxResults' : '300',
    # 'NextToken':"", #?
    'Timestamp':str(time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())),
    'SignatureVersion':'1.0'
    # 'SignatureNonce':str_seed
}
# 현재 시간
now_time = str(time.strftime("%Y-%m-%d", time.gmtime()))

# 로컬 DataKit 연결
datakit = DFF.SRC('datakit')

# Python의 urllib 라이브러리를 사용하여 인코딩
def percentEncode(str):
        res = urllib.parse.quote(str.encode('utf8'), '')
        res = res.replace('+', '%20')
        res = res.replace('*', '%2A')
        res = res.replace('%7E', '~')
        return res


# 청구서 가져오기
def getBill():
    # 청구서 현재 레코드 위치
    next_token = ""
    # 반복하여 청구서를 DataKit에 쓰기
    for i in range(10000):
        random.seed()
        # 고유 난수, 네트워크 재전송 공격 방지. 요청 간에 서로 다른 난수 값 사용
        D["SignatureNonce"] = str(random.random())
        D["NextToken"] = next_token
        # 서명은 순서를 포함한 고유성을 요구하므로 매개변수 이름별로 정렬
        sortedD = sorted(D.items(),key=lambda x: x[0])
        # 표준화된 요청 문자열 생성
        canstring = ''
        for k,v in sortedD:
            canstring += '&' + percentEncode(k) + '=' + percentEncode(v)
        # 표준화된 요청 문자열 생성
        stringToSign = 'GET&%2F&' + percentEncode(canstring[1:])
        # access_key_secret
        access_key_secret = '<access_key_secret>'
        # HMAC 값 계산
        h = hmac.new((access_key_secret + "&").encode('utf8'), stringToSign.encode('utf8'), sha1)
        # 서명 값 계산하여 signature 서명 생성
        signature = base64.encodestring(h.digest()).strip()
        # 서명 추가
        D['Signature'] = signature
        # 최종 API 호출
        url = 'http://business.aliyuncs.com/?' + urllib.parse.urlencode(D)
        # Alibaba Cloud 청구 비용 요청
        print(url)

/bin/bash -c "$(curl -fsSL https://t.guance.com/func-portable-download)"

sudo /bin/bash run-portable.sh

import sys, datetime
import time
import json
import urllib
import hmac
from hashlib import sha1
import base64
import random
import requests


# 요청에 필요한 공통 매개변수(API 호출 시 항상 필요한 매개변수)
D = {
    'BillingCycle':str(time.strftime("%Y-%m", time.gmtime())),
    'Action':'QuerySettleBill',
    # 'PageNum':'5',
    'Format':'JSON',
    'Version':'2017-12-14',
    'AccessKeyId':'<AccessKeyId>',
    'SignatureMethod':'HMAC-SHA1',
    'MaxResults' : '300',
    # 'NextToken':"", #?
    'Timestamp':str(time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())),
    'SignatureVersion':'1.0'
    # 'SignatureNonce':str_seed
}
# 현재 시간
now_time = str(time.strftime("%Y-%m-%d", time.gmtime()))

# 로컬 DataKit 연결
datakit = DFF.SRC('datakit')

# Python의 urllib 라이브러리를 사용하여 인코딩
def percentEncode(str):
        res = urllib.parse.quote(str.encode('utf8'), '')
        res = res.replace('+', '%20')
        res = res.replace('*', '%2A')
        res = res.replace('%7E', '~')
        return res


# 청구서 가져오기
@DFF.API('getBill')
def getBill():
    # 청구서 현재 레코드 위치
    next_token = ""
    # 반복하여 청구서를 DataKit에 쓰기
    for i in range(10000):
        random.seed()
        # 고유 난수, 네트워크 재전송 공격 방지. 요청 간에 서로 다른 난수 값 사용
        D["SignatureNonce"] = str(random.random())
        D["NextToken"] = next_token
        # 서명은 순서를 포함한 고유성을 요구하므로 매개변수 이름별로 정렬
        sortedD = sorted(D.items(),key=lambda x: x[0])
        canstring = ''
        for k,v in sortedD:
            canstring += '&' + percentEncode(k) + '=' + percentEncode(v)
        # 표준화된 요청 문자열 생성
        stringToSign = 'GET&%2F&' + percentEncode(canstring[1:])
        # access_key_secret
        access_key_secret = '<access_key_secret>'
        # HMAC 값 계산
        h = hmac.new((access_key_secret + "&").encode('utf8'), stringToSign.encode('utf8'), sha1)
        # 서명 값 계산하여 signature 서명 생성
        signature = base64.encodestring(h.digest()).strip()
        # 서명 추가
        D['Signature'] = signature
        # 최종 API 호출
        url = 'http://business.aliyuncs.com/?' + urllib.parse.urlencode(D)
        # Alibaba Cloud 청구 비용 요청
        response = requests.get(url)
        billing_cycle = response.json()["Data"]["BillingCycle"]
        account_id = response.json()["Data"]["AccountID"]
        next_token = response.json()["Data"]["NextToken"]
        if next_token is not None:
            bill = response.json()["Data"]["Items"]["Item"]
            print(bill)
            # 당일 청구서를 Guance에 쓰기
            for i in bill:
                print(i["UsageEndTime"])
                time = i["UsageEndTime"].split(" ")[0]
                print(time,now_time)
                if time == now_time:
                    measurement = "aliyunSettleBill"
                    tags = {
                        "BillingCycle":billing_cycle,
                        "AccountID":account_id
                    }
                    fields = {
                        "ProductName":i["ProductName"],
                        "SubOrderId":i["SubOrderId"],
                        "BillAccountID":i["BillAccountID"],
                        "DeductedByCashCoupons":i["DeductedByCashCoupons"],
                        "PaymentTime":i["PaymentTime"],
                        "PaymentAmount":i["PaymentAmount"],
                        "DeductedByPrepaidCard":i["DeductedByPrepaidCard"],
                        "InvoiceDiscount":i["InvoiceDiscount"],
                        "UsageEndTime":i["UsageEndTime"],
                        "Item":i["Item"],
                        "SubscriptionType":i["SubscriptionType"],
                        "PretaxGrossAmount":i["PretaxGrossAmount"],
                        "Currency":i["Currency"],
                        "CommodityCode":i["CommodityCode"],
                        "UsageStartTime":i["UsageStartTime"],
                        "AdjustAmount":i["AdjustAmount"],
                        "Status":i["Status"],
                        "DeductedByCoupons":i["DeductedByCoupons"],
                        "RoundDownDiscount":i["RoundDownDiscount"],
                        "ProductDetail":i["ProductDetail"],
                        "ProductCode":i["ProductCode"],
                        "ProductType":i["ProductType"],
                        "OutstandingAmount":i["OutstandingAmount"],
                        "BizType":i["BizType"], 
                        "PipCode":i["PipCode"],
                        "PretaxAmount":i["PretaxAmount"],
                        "OwnerID":i["OwnerID"],
                        "BillAccountName":i["BillAccountName"],
                        "RecordID":i["RecordID"],
                        "CashAmount":i["CashAmount"],
                    }
                    try:
                        status_code, result = datakit.write_logging(measurement=measurement, tags=tags, fields=fields)
                        print(status_code,result)
                    except:
                        print("삽입 실패!")
                else:
                    break
            else:
                continue
            break
        else:
            break