https://dwt.life/tag/loki/ https://dwt.life/archives/244/ 2022-05-16T19:15:04+08:00 仅用于参考auth_enabled: false server: http_listen_port: 3100 # grpc_listen_port: 9096 common: path_prefix: /tmp/loki replication_factor: 1 ring: instance_addr: 127.0.0.1 kvstore: store: inmemory schema_config: configs: - from: 2020-10-24 store: boltdb-shipper object_store: aws schema: v11 index: prefix: index_ period: 24h storage_config: aws: bucketnames: loki-logs-123123 # 请在腾讯云创建一个对象存储存储桶，并把存储桶名称写到这里 endpoint: cos.ap-guangzhou.myqcloud.com # 腾讯云的对象存储域名后缀 access_key_id: <Your access key id from TencentCloud> # 腾讯云 AK secret_access_key: <Your secret access key from TencentCloud> # 腾讯云 SK region: ap-guang # 对象存储存储桶地域 boltdb_shipper: active_index_directory: /loki/index shared_store: s3 cache_location: /loki/boltdb-cache compactor: working_directory: /loki/boltdb-shipper-compactor shared_store: aws ruler: alertmanager_url: http://localhost:9093 analytics: reporting_enabled: false https://dwt.life/archives/243/ 2022-05-16T19:07:30+08:00 package main import ( "flag" "fmt" "os" "reflect" "runtime" "github.com/go-kit/log/level" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/common/version" "github.com/weaveworks/common/logging" "github.com/weaveworks/common/tracing" "github.com/grafana/loki/pkg/loki" "github.com/grafana/loki/pkg/util" _ "github.com/grafana/loki/pkg/util/build" "github.com/grafana/loki/pkg/util/cfg" util_log "github.com/grafana/loki/pkg/util/log" "github.com/grafana/loki/pkg/validation" ) func main() { var config loki.ConfigWrapper if err := cfg.DynamicUnmarshal(&config, os.Args[1:], flag.CommandLine); err != nil { fmt.Fprintf(os.Stderr, "failed parsing config: %v\n", err) os.Exit(1) } if config.PrintVersion { fmt.Println(version.Print("loki")) os.Exit(0) } // This global is set to the config passed into the last call to `NewOverrides`. If we don't // call it atleast once, the defaults are set to an empty struct. // We call it with the flag values so that the config file unmarshalling only overrides the values set in the config. validation.SetDefaultLimitsForYAMLUnmarshalling(config.LimitsConfig) // Init the logger which will honor the log level set in config.Server if reflect.DeepEqual(&config.Server.LogLevel, &logging.Level{}) { level.Error(util_log.Logger).Log("msg", "invalid log level") os.Exit(1) } util_log.InitLogger(&config.Server, prometheus.DefaultRegisterer) // Validate the config once both the config file has been loaded // and CLI flags parsed. err := config.Validate() if err != nil { level.Error(util_log.Logger).Log("msg", "validating config", "err", err.Error()) os.Exit(1) } if config.PrintConfig { err := util.PrintConfig(os.Stderr, &config) if err != nil { level.Error(util_log.Logger).Log("msg", "failed to print config to stderr", "err", err.Error()) } } if config.LogConfig { err := util.LogConfig(&config) if err != nil { level.Error(util_log.Logger).Log("msg", "failed to log config object", "err", err.Error()) } } if config.VerifyConfig { level.Info(util_log.Logger).Log("msg", "config is valid") os.Exit(0) } if config.Tracing.Enabled { // Setting the environment variable JAEGER_AGENT_HOST enables tracing trace, err := tracing.NewFromEnv(fmt.Sprintf("loki-%s", config.Target)) if err != nil { level.Error(util_log.Logger).Log("msg", "error in initializing tracing. tracing will not be enabled", "err", err) } defer func() { if trace != nil { if err := trace.Close(); err != nil { level.Error(util_log.Logger).Log("msg", "error closing tracing", "err", err) } } }() } // Allocate a block of memory to reduce the frequency of garbage collection. // The larger the ballast, the lower the garbage collection frequency. // https://github.com/grafana/loki/issues/781 ballast := make([]byte, config.BallastBytes) runtime.KeepAlive(ballast) // Start Loki t, err := loki.New(config.Config) util_log.CheckFatal("initialising loki", err, util_log.Logger) if config.ListTargets { t.ListTargets() os.Exit(0) } level.Info(util_log.Logger).Log("msg", "Starting Loki", "version", version.Info()) err = t.Run(loki.RunOpts{}) util_log.CheckFatal("running loki", err, util_log.Logger) }https://github.com/grafana/loki/blob/main/cmd/loki/main.go