Compute Nest:PushMeteringData - Dorong data metering

Python

import requests
import json
import hashlib
import time
from urllib.request import urlopen

def get_region_id():
    """Dapatkan ID wilayah (misalnya cn-hangzhou) melalui layanan metadata Alibaba Cloud"""
    try:
        with urlopen(
            "http://100.100.100.200/latest/meta-data/region-id",
            timeout=2
        ) as response:
            return response.read().decode().strip()
    except Exception as e:
        print(f"Gagal mendapatkan ID wilayah: {str(e)}", file=sys.stderr)
        sys.exit(1)

def push_metering_data(entities_map, service_key):
    # Dapatkan waktu saat ini secara dinamis (stempel waktu Unix dalam detik)
    current_time = int(time.time())
    start_time = current_time
    end_time = current_time + 1

    # Bangun data Metering
    metering_data = [
        {
            "StartTime": str(start_time),
            "EndTime": str(end_time),
            "Entities": [
                {"Key": key, "Value": str(value)}
                for key, value in entities_map.items()
            ]
        }
    ]
    metering_str = json.dumps(metering_data)

    # Dapatkan ID wilayah secara dinamis dan bangun URL
    region_id = get_region_id()
    url = f"https://{region_id}.axt.aliyun.com/computeNest/marketplace/push_metering_data"

    # Hitung Token
    token_str = metering_str + "&" + service_key
    token = hashlib.md5(token_str.encode()).hexdigest().lower()

    # Kirim permintaan POST
    try:
        response = requests.post(
            url,
            json={
                "Metering": metering_str,
                "Token": token
            },
            headers={"Content-Type": "application/json"}
        )
        print(f"URL Permintaan: {url}")
        print(f"Kode Status: {response.status_code}")
        print(f"Tanggapan: {response.text}")
    except Exception as e:
        print(f"Permintaan Gagal: {str(e)}", file=sys.stderr)

if __name__ == "__main__":
    import sys
    # Parameter contoh (ganti dengan data dorong aktual, kunci adalah item metering, nilai adalah nilainya)
    entities = {
        "Frequency": "6"
    }
    # Kunci penyedia layanan
    service_key = "your_service_key_here"

    # Panggil fungsi
    push_metering_data(entities, service_key)

Contoh eksekusi:

Java

import org.json.JSONArray;
import org.json.JSONObject;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.MessageDigest;
import java.util.HashMap;
import java.util.Map;

public class MeteringPusher {
    public static void main(String[] args) {
        try {
            // === Dapatkan ID wilayah secara dinamis === #
            String regionId = getRegionId();
            System.out.println("ID Wilayah Terdeteksi: " + regionId);

            // === Bangun badan permintaan === #
            Map<String, String> entities = new HashMap<>(); // Bangun Entities, ganti dengan konten dorong aktual
            entities.put("Frequency", "6");
            String serviceKey = "your_service_key_here"; // Ganti dengan Kunci penyedia layanan aktual
            JSONObject payload = generateDynamicRequest(regionId, entities, serviceKey);
            String paylodString = payload.toString();

            // Jika hanya untuk pengujian, Anda dapat memberi komentar pada konten di atas dan langsung memasukkan konten berikut, 
            // di mana StartTime, EndTime, dan parameter lainnya perlu diganti
            // String paylodString = "{\"Metering\":\"[{\\\"StartTime\\\":\\\"1664451045\\\",\\\"EndTime\\\":\\\"1664451198\\\",\\\"Entities\\\":[{\\\"Key\\\":\\\"Frequency\\\",\\\"Value\\\":\\\"6\\\"}]}]\",\"Token\":\"7aa81300b2aea77984b772495c8e4e83\"}";

            // === Kirim permintaan POST === #
            String urlStr = "https://" + regionId + ".axt.aliyun.com/computeNest/marketplace/push_metering_data";
            URL url = new URL(urlStr);
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setDoOutput(true);

            try (OutputStream os = conn.getOutputStream()) {
                byte[] input = paylodString.getBytes("UTF-8");
                os.write(input, 0, input.length);
            }

            // === Baca tanggapan === #
            BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            StringBuilder response = new StringBuilder();
            String responseLine;
            while ((responseLine = br.readLine()) != null) {
                response.append(responseLine);
            }
            conn.disconnect();
            System.out.println("Tanggapan: " + response.toString());
            System.out.println("URL Permintaan: " + urlStr);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // === Dapatkan ID wilayah secara dinamis (layanan metadata Alibaba Cloud) ===
    private static String getRegionId() throws Exception {
        String regionIdUrl = "http://100.100.100.200/latest/meta-data/region-id";
        HttpURLConnection conn = (HttpURLConnection) new URL(regionIdUrl).openConnection();
        conn.setRequestMethod("GET");
        conn.setConnectTimeout(2000); // timeout 2 detik
        conn.setReadTimeout(2000);

        try (BufferedReader in = new BufferedReader(
            new InputStreamReader(conn.getInputStream()))) {
            return in.readLine().trim();
        }
    }

    //  === Hasilkan data permintaan secara dinamis  ===
    private static JSONObject generateDynamicRequest(String regionId, Map<String, String> entities, String serviceKey) throws Exception {
        // Dapatkan stempel waktu saat ini
        long currentTime = System.currentTimeMillis() / 1000;
        long startTime = currentTime;
        long endTime = currentTime + 1;

        // Bangun data Metering
        JSONArray meteringArray = new JSONArray();
        JSONObject meteringItem = new JSONObject();
        meteringItem.put("StartTime", String.valueOf(startTime));
        meteringItem.put("EndTime", String.valueOf(endTime));

        JSONArray entitiesArray = new JSONArray();
        for (Map.Entry<String, String> entry : entities.entrySet()) {
            entitiesArray.put(new JSONObject()
                .put("Key", entry.getKey())
                .put("Value", entry.getValue()));
        }
        meteringItem.put("Entities", entitiesArray);
        meteringArray.put(meteringItem);

        // Hitung Token
        String meteringStr = meteringArray.toString();
        String tokenStr = meteringStr + "&" + serviceKey;
        String token = md5(tokenStr);

        // Bangun badan permintaan lengkap
        JSONObject payload = new JSONObject();
        payload.put("Metering", meteringStr);
        payload.put("Token", token);
        return payload;
    }

    // === Metode enkripsi MD5 ===
    private static String md5(String input) throws Exception {
        MessageDigest md = MessageDigest.getInstance("MD5");
        byte[] messageDigest = md.digest(input.getBytes());
        StringBuilder hexString = new StringBuilder();
        for (byte b : messageDigest) {
            String hex = Integer.toHexString(0xff & b);
            if (hex.length() == 1) hexString.append('0');
            hexString.append(hex);
        }
        return hexString.toString();
    }
}

Contoh eksekusi:

<dependency>
    <groupId>org.json</groupId>
    <artifactId>json</artifactId>
    <version>20230618</version>
</dependency>