Utilisez le SDK Simple Log Service pour C++ afin d'initialiser un client et d'effectuer des opérations courantes, telles que l'écriture et la requête de journaux.
Prérequis
-
SDK Simple Log Service pour C++ installé. Pour les instructions d'installation, consultez la rubrique Installer le SDK Simple Log Service pour C++.
Exemple de code
LogClient est le client C++ permettant de gérer les ressources Simple Log Service, telles que les projets et les Logstores. Initialisez une instance de client avant d'envoyer des requêtes. L'exemple suivant montre comment écrire des journaux, interroger des journaux et gérer des groupes de consommateurs :
#include "client.h"
#include "common.h"
#include <string>
#include <cstdlib>
#include <iostream>
#include <unistd.h>
using namespace aliyun_log_sdk_v6;
using namespace std;
int main(int argc,char ** argv)
{
// The Simple Log Service endpoint. Replace with the endpoint for your region.
string endpoint = "cn-hangzhou.log.aliyuncs.com";
// Obtain the AccessKey ID and AccessKey Secret from environment variables.
string accessKeyId = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
string accessKey = (string)getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
// Specify the project name.
string project = "";
// Specify the Logstore name.
string logstore = "";
// Specify the log topic.
string topic = "";
// Initialize the Simple Log Service client.
LOGClient * ptr = new LOGClient(endpoint,accessKeyId,accessKey,LOG_REQUEST_TIMEOUT,"127.0.0.1",false);
// Construct log data.
vector<LogItem> logGroup;
for (int i = 0;i < 1;++i)
{
logGroup.push_back(LogItem());
LogItem & item = logGroup.back();
item.timestamp = time(NULL) ;
item.source="127.0.0.1";
item.topic=topic;
item.data.push_back(make_pair<string,string>("status","200"));
item.data.push_back(make_pair<string,string>("latency","126"));
}
try{
// Write logs.
ptr -> DeleteConsumerGroup(project,logstore,"test-consumer-group");
uint32_t shardId = 2;
int32_t beginTime = time(NULL);
ptr -> PostLogStoreLogs(project,logstore,topic,logGroup);
sleep(1);
ptr -> PostLogStoreLogs(project,logstore,topic,logGroup);
sleep(1);
int32_t endTime = time(NULL);
ptr -> PostLogStoreLogs(project,logstore,topic,logGroup);
sleep(1);
ptr -> PostLogStoreLogs(project,logstore,topic,logGroup);
sleep(1);
// Query logs.
GetCursorResponse beginCursorResp = ptr->GetCursor(project, logstore, shardId, beginTime);
GetCursorResponse endCursorResp = ptr->GetCursor(project, logstore, shardId, endTime);
GetBatchLogResponse getLogResp = ptr->GetBatchLog(project, logstore, shardId, 1000, beginCursorResp.result);
cout << getLogResp.result.logGroups.size() << "\t" << getLogResp.result.logGroupCount << endl;
getLogResp = ptr->GetBatchLog(project, logstore, 2, 1000, beginCursorResp.result, endCursorResp.result);
cout << getLogResp.result.logGroups.size() << "\t" << getLogResp.result.logGroupCount << endl;
ListConsumerGroupResponse lrs = ptr -> ListConsumerGroup(project, logstore);
for(int i = 0; i < lrs.consumerGroups.size(); ++i)
cout<<lrs.consumerGroups[i].GetConsumerGroupName()<<", " <<lrs.consumerGroups[i].GetTimeoutInSec()<<", " <<lrs.consumerGroups[i].GetInOrder()<<endl;
ptr->UpdateCheckpoint(project, logstore, "hahhah", 0, "V0hBVFRIRlVDSw==");
ListCheckpointResponse lcps = ptr -> ListCheckpoint(project, logstore, "hahhah");
for(int i =0; i < lcps.consumerGroupCheckpoints.size(); ++i)
{
cout<<lcps.consumerGroupCheckpoints[i].GetShard() <<", " << lcps.consumerGroupCheckpoints[i].GetCheckpoint()<<", "<<lcps.consumerGroupCheckpoints[i].GetUpdateTime()<<endl;
}
while(true){
HeartbeatResponse resp = ptr->ConsumerGroupHeartbeat(project, logstore, "hahhah", "cc1", std::vector<uint32_t>());
cout<<"cc1, heartbeat: ";
for(std::vector<uint32_t>::const_iterator it = resp.shards.begin(); it != resp.shards.end(); ++it)
cout<<*it<<", ";
cout<<endl;
resp = ptr->ConsumerGroupHeartbeat(project, logstore, "hahhah", "cc2", std::vector<uint32_t>());
cout<<"cc2, heartbeat: ";
for(std::vector<uint32_t>::const_iterator it = resp.shards.begin(); it != resp.shards.end(); ++it)
cout<<*it<<", ";
cout<<endl;
usleep(2 * 1000 * 1000);
}
}
catch(LOGException & e)
{
cout<<e.GetErrorCode()<<":"<<e.GetMessage()<<endl;
}
delete ptr;
}