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