import com.tencentcloudapi.cls.sdk.AsyncProducerClient;
import com.tencentcloudapi.cls.sdk.AsyncProducerConfig;
import com.tencentcloudapi.cls.sdk.LogItem;
import com.tencentcloudapi.cls.sdk.LogContent;
import com.tencentcloudapi.cls.sdk.NetworkUtils;

import java.util.ArrayList;
import java.util.List;

public class TencentClsDemo {
    public static void main(String[] args) {
        // ドメイン名情報を入力してください。ドメイン名については、リンク内のAPIアップロードログタブにあるドメイン名を参照してください：https://www.tencentcloud.com/document/product/614/18940#.E5.9F.9F.E5.90.8D
        String endpoint = "ap-xxxxxx.cls.tencentcs.com";  
        // TencentCloud APIキー情報を入力してください。キー情報の取得はこちらから：https://console.tencentcloud.com/cam/capi
        // また、キーに関連付けられたアカウントに、対応するログアップロード権限が付与されていることを確認してください。権限設定ガイド：https://www.tencentcloud.com/document/product/614/45004#.E4.BD.BF.E7.94.A8-api-.E4.B8.8A.E4.BC.A0.E6.95.B0.E6.8D.AE
        // この例では環境変数から取得します。環境変数設定ガイド：https://www.tencentcloud.com/document/product/614/113851?from_cn_redirect=1
        String secretId = System.getenv("TENCENTCLOUD_SECRET_ID");
        String secretKey = System.getenv("TENCENTCLOUD_SECRET_KEY");
        
        // ログトピックIDを入力してください。
        String topicId = "5912XXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";

        final AsyncProducerConfig config = new AsyncProducerConfig(endpoint, secretId, secretKey, NetworkUtils.getLocalMachineIP());

        // クライアントインスタンスを構築します。
        final AsyncProducerClient client = new AsyncProducerClient(config);

        for (int i = 0; i < 10000; ++i) {
            List<LogItem> logItems = new ArrayList<>();
            int ts = (int) (System.currentTimeMillis() / 1000);
            LogItem logItem = new LogItem(ts);
            logItem.PushBack(new LogContent("__CONTENT__", "hello world"));
            logItem.PushBack(new LogContent("city", "guangXXXXX"));
            logItem.PushBack(new LogContent("logNo", Integer.toString(i)));
            logItem.PushBack(new LogContent("__PKG_LOGID__", (String.valueOf(System.currentTimeMillis()))));
            logItems.add(logItem);
            client.putLogs(topicId, logItems, result -> System.out.println(result.toString()));
        }
        client.close();
    }
}