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 上传日志 Tab 中的域名：https://www.tencentcloud.com/document/product/614/18940?from_cn_redirect=1#.E5.9F.9F.E5.90.8D
        String endpoint = "ap-xxxxxx.cls.tencentcs.com";  
        // 填入云API密钥信息。密钥信息获取请前往：https://console.tencentcloud.com/cam/capi
        // 并请确保密钥关联的账号具有相应的日志上传权限，权限配置指引：https://www.tencentcloud.com/document/product/614/68374?from_cn_redirect=1#.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();
    }
}