package com.tencentcloudapi.cls;import com.tencentcloudapi.cls.producer.errors.ProducerException;import org.junit.Test;public class AsyncProducerClientTest {@Testpublic void testAsyncProducerClient() throws ProducerException, InterruptedException {String endpoint = "ap-guangzhou.cls.tencentcs.com";// API key secretId, required.String secretId = "";// API key secretKey, required.String secretKey = "";// API token, required.String secretToken = "";// Log topic ID, required.String topicId = "";final AsyncProducerConfig config = new AsyncProducerConfig(endpoint, secretId, secretKey,NetworkUtils.getLocalMachineIP(), secretToken);// Build a client instance.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, I am from Shenzhen.|hello world"));logItem.PushBack(new LogContent("city", "guangzhou"));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();}}
Feedback