亚洲欧洲日产国码无码,国产精品久久久久影院,青草草超碰97资讯

日志上下文查詢用于指定日志來源（例如，特定的機(jī)器和文件），并查找該來源中某條日志的前后若干條日志，以獲取其上下文信息。在處理大量日志時(shí)，可通過為日志添加標(biāo)識符 PackId 將相關(guān)日志進(jìn)行分組。使用 PackId 可以快速且完整地查詢相關(guān)日志組，從而高效定位日志的上下文。本文介紹如何為日志添加PackId。

工作原理

服務(wù)端利用PackId機(jī)制關(guān)聯(lián)日志上下文，PackId格式為上下文前綴-日志組ID，例如 5FA51423DDB54FDA-1E3。說明如下：

上下文前綴：由大寫字母和數(shù)字組成，例如 5FA51423DDB54FDA。相同上下文前綴表示屬于同一日志上下文。
日志組ID：由大寫的十六進(jìn)制數(shù)字表示。例如 1E3。在同一日志上下文內(nèi)，日志組ID 是遞增的，例如 1E3 與 1E4屬于同一日志上下文的相鄰日志組。

PackId是由客戶端生成的，并在日志寫入請求時(shí)一同發(fā)送到服務(wù)端。具有相同上下文前綴的日志被認(rèn)為屬于同一日志上下文。

自動(dòng)生成PackId

使用Producer SDK寫入的日志：由同一Producer對象實(shí)例發(fā)送的日志數(shù)據(jù)屬于同一上下文，可以直接用于上下文查詢。例如，當(dāng)使用Aliyun Log Java Producer寫入日志數(shù)據(jù)或C SDK寫入日志時(shí)，系統(tǒng)會自動(dòng)生成并攜帶PackId作為上下文標(biāo)識。
通過Logtail采集的日志：使用Logtail采集的日志會自動(dòng)生成并攜帶PackId，同一采集對象（如主機(jī)、pod等）上的同一日志文件屬于同一上下文，可以直接用于上下文查詢。

手動(dòng)生成PackId并通過PutLogs接口上傳

參數(shù)說明

PutLogs - 寫入日志接口用于將日志寫入日志服務(wù)。在手動(dòng)生成PackId后，需將該P(yáng)ackId放置在PutLogs請求中的LogGroup的LogTags屬性里，其中Key設(shè)定為__pack_id__，參數(shù)示例如下：

{
  "Topic": "my-topic",
  "Source": "127.0.0.1",
  "LogTags": [
      {
        "Key": "__pack_id__",
        "Value": "5FA51423DDB54FDA-1"
      },
      {
        "Key": "my_other_tag_key",
        "Value": "my_other_tag_value"
      }
   ],
   "Logs": [
     {
       "Time": 1728961415,
        "Contents": [
            {
              "Key": "hello",
              "Value": "world"
            }
        ]
     }
   ]
}

示例代碼

Java示例

在pom.xml文件中添加如下依賴。

 <dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>27.0.1-jre</version>
</dependency>
<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>aliyun-log</artifactId>
    <version>0.6.111</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>2.0.12</version>
</dependency>

使用如下代碼，手動(dòng)生成PackId并通過PutLogs接口上傳。根據(jù)實(shí)際情況替換參數(shù)project、logstore、endpoint、accessKeyId和accessKeySecret。

package org.example;

import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.LogItem;
import com.aliyun.openservices.log.common.TagContent;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.PutLogsRequest;
import com.google.common.base.Charsets;
import com.google.common.hash.Hashing;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.lang.management.ManagementFactory;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Enumeration;
import java.util.List;
import java.util.concurrent.atomic.AtomicLong;

public class Main {
    private static final String TAG_PACK_ID = "__pack_id__";
    private static final int TOKEN_LEN = 4;

    public static void main(String[] args) throws LogException {
        System.out.println("Hello world!");
        // 同一個(gè)上下文只需要使用同一個(gè) PackIdGenerator 就可以了
        PackIdGenerator generator1 = new PackIdGenerator();
        System.out.println(generator1.generateNewPackId());
        System.out.println(generator1.generateNewPackId());
        System.out.println(generator1.generateNewPackId());
        // 不同的上下文用不同的 PackIdGenerator
        PackIdGenerator generator2 = new PackIdGenerator();
        System.out.println(generator2.generateNewPackId());
        System.out.println(generator2.generateNewPackId());

        // 與日志相配合
        String project = "project";
        String logstore = "logstore";
        String topic = "topic";
        String source = "127.0.0.1";
        Client client = new Client("endpoint", "accessKeyId", "accessKeySecret");
        List<LogItem> logs = new ArrayList<>();
        LogItem log = new LogItem();
        log.PushBack("hello", "world");
        logs.add(log);

        // 發(fā)送日志請求
        PutLogsRequest req = new PutLogsRequest(project, logstore, topic, source, logs);
        // 把 pack id 放在 tag 列表里
        req.SetTags(Arrays.asList(new TagContent(TAG_PACK_ID, generator1.generateNewPackId())));
        client.PutLogs(req);

        // 發(fā)送日志請求
        PutLogsRequest req2 = new PutLogsRequest(project, logstore, topic, source, logs);
        req.SetTags(Arrays.asList(new TagContent(TAG_PACK_ID, generator1.generateNewPackId())));
        client.PutLogs(req2);
    }

    public static class NetworkUtils {
        private NetworkUtils() {
        }

        public static boolean isIpAddress(final String ipAddress) {
            if (ipAddress == null || ipAddress.isEmpty()) {
                return false;
            }
            try {
                final String[] tokens = ipAddress.split("\\.");
                if (tokens.length != TOKEN_LEN) {
                    return false;
                }
                for (String token : tokens) {
                    int i = Integer.parseInt(token);
                    if (i < 0 || i > 255) {
                        return false;
                    }
                }
                return true;
            } catch (Exception ex) {
                return false;
            }
        }

        public static String getLocalMachineIp() {
            try {
                Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces();
                while (networkInterfaces.hasMoreElements()) {
                    NetworkInterface ni = networkInterfaces.nextElement();
                    if (!ni.isUp()) {
                        continue;
                    }
                    Enumeration<InetAddress> addresses = ni.getInetAddresses();
                    while (addresses.hasMoreElements()) {
                        final InetAddress address = addresses.nextElement();
                        if (!address.isLinkLocalAddress() && address.getHostAddress() != null) {
                            String ipAddress = address.getHostAddress();
                            if ("127.0.0.1".equals(ipAddress)) {
                                continue;
                            }
                            if (isIpAddress(ipAddress)) {
                                return ipAddress;
                            }
                        }
                    }
                }
            } catch (SocketException ex) {
                // swallow it
            }
            return null;
        }
    }

    public static class PackIdGenerator {
        private static final Logger LOGGER = LoggerFactory.getLogger(PackIdGenerator.class);
        private static final AtomicLong GENERATORID = new AtomicLong(0);
        private final String packIdPrefix;
        private final AtomicLong batchId = new AtomicLong(0);

        public PackIdGenerator() {
            packIdPrefix = generatePackIdPrefix(GENERATORID.getAndIncrement()).toUpperCase() + "-";
        }

        public String generateNewPackId() {
            return packIdPrefix + Long.toHexString(batchId.getAndIncrement()).toUpperCase();
        }

        private String generatePackIdPrefix(Long instanceId) {
            String ip = NetworkUtils.getLocalMachineIp();
            if (ip == null) {
                LOGGER.warn("Failed to get local machine ip, set ip to 127.0.0.1");
                ip = "127.0.0.1";
            }
            String name = ManagementFactory.getRuntimeMXBean().getName();
            String input = ip + "-" + name + "-" + instanceId;
            return Hashing.farmHashFingerprint64().hashString(input, Charsets.US_ASCII).toString();
        }
    }

}

示例代碼中的參數(shù)說明

參數(shù)名	參數(shù)含義	示例值
project	日志服務(wù)的Project名。	test-project
logstore	日志服務(wù)的Logstore名。	test-logstore
endpoint	日志服務(wù)的公網(wǎng)域名，獲取方式請參見服務(wù)接入點(diǎn)。	cn-hangzhou.log.aliyuncs.com
accessKeyId	用戶身份識別ID，獲取方式，請參見創(chuàng)建AccessKey。	LTAI5tK*******
accessKeySecret	用于驗(yàn)證您擁有該AccessKey ID的密碼。獲取方式，請參見創(chuàng)建AccessKey。	3k5PJm*******

Go示例

在命令行執(zhí)行如下命令，安裝Go SDK和protobuf依賴包。

go get -u github.com/aliyun/aliyun-log-go-sdk
go get google.golang.org/protobuf