Golang Elastic APM – 保存定时任务的事务记录

huangapple
go评论119阅读模式
英文:

Golang Elastic APM - save transactions of cronjob

问题

Golang Elastic APM - 保存 cronjob 的事务

我需要将 Elastic APM 连接到我的 cronjob，但是当我按照 APM 文档 进行操作时，我发现没有事务甚至没有服务注册。

我该如何连接 APM 并为 cronjob 注册事务，而不是为 api 注册事务？

  • main.go
  1. package main
  3. import (
  4. 	"context"
  5. 	"errors"
  6. 	"math/rand"
  7. 	"time"
  9. 	"go.elastic.co/apm/v2"
  10. )
  12. func main() {
  13. 	// export ELASTIC_APM_SERVICE_NAME=test
  14. 	t := apm.DefaultTracer().StartTransaction("test-name", "test-group")
  15. 	c := apm.ContextWithTransaction(context.Background(), t)
  16. 	worker(c)
  17. 	t.End()
  19. 	time.Sleep(time.Second * 5)
  20. }
  22. func worker(c context.Context) {
  23. 	span, c := apm.StartSpan(c, "one", "test-type")
  25. 	e := apm.DefaultTracer().Recovered(errors.New("test-error"))
  26. 	e.SetSpan(span)
  27. 	e.Send()
  29. 	// do some work
  30. 	time.Sleep(time.Duration(rand.Intn(300-100)+300) * time.Millisecond)
  31. 	span.End()
  33. 	two(c)
  34. }
  36. func two(c context.Context) {
  37. 	span, _ := apm.StartSpan(c, "two", "test-type")
  38. 	// do some other work
  39. 	time.Sleep(time.Duration(rand.Intn(100-50)+100) * time.Millisecond)
  40. 	span.End()
  41. }
  • docker-compose.yaml 用于在本地运行 APM
  1. version: '3.8'
  3. services:
  5.   apm-server:
  6.     image: docker.elastic.co/apm/apm-server:7.15.0
  7.     cap_add: ["CHOWN", "DAC_OVERRIDE", "SETGID", "SETUID"]
  8.     cap_drop: ["ALL"]
  9.     ports:
  10.     - 8200:8200
  11.     command: >
  12.        apm-server -e
  13.          -E apm-server.rum.enabled=true
  14.          -E setup.kibana.host=kibana:5601
  15.          -E setup.template.settings.index.number_of_replicas=0
  16.          -E apm-server.kibana.enabled=true
  17.          -E apm-server.kibana.host=kibana:5601
  18.          -E output.elasticsearch.hosts=["elasticsearch:9200"]       
  19.     healthcheck:
  20.       interval: 10s
  21.       retries: 12
  22.       test: curl --write-out 'HTTP %{http_code}' --fail --silent --output /dev/null http://localhost:8200/
  23.     networks:
  24.       - elastic
  26.   elasticsearch:
  27.    container_name: elasticsearch
  28.    image: docker.elastic.co/elasticsearch/elasticsearch:7.15.0
  29.    ports:
  30.     - 9200:9200
  31.    environment:
  32.     - xpack.monitoring.enabled=true
  33.     - xpack.watcher.enabled=false
  34.     - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
  35.     - discovery.type=single-node
  36.    networks:
  37.     - elastic
  39.   kibana:
  40.    container_name: kibana
  41.    image: docker.elastic.co/kibana/kibana:7.15.0
  42.    ports:
  43.     - 5601:5601
  44.    depends_on:
  45.     - elasticsearch
  46.    environment:
  47.     - ELASTICSEARCH_URL=http://localhost:9200
  48.     - xpack.apm.enabled=false
  49.    networks:
  50.     - elastic
  52.   
  53. networks:
  54.   elastic:
  55.     driver: bridge
英文:

Golang Elastic APM - save transactions of cronjob

I need to connect Elastic APM to my cronjob however I when I follow documentation for APM I see no transactions or even service registered.

How can I connect APM and register transactions for cronjob and not for api

  • main.go
  1. package main
  3. import (
  4. 	"context"
  5. 	"errors"
  6. 	"math/rand"
  7. 	"time"
  9. 	"go.elastic.co/apm/v2"
  10. )
  12. func main() {
  13. 	// export ELASTIC_APM_SERVICE_NAME=test
  14. 	t := apm.DefaultTracer().StartTransaction("test-name", "test-group")
  15. 	c := apm.ContextWithTransaction(context.Background(), t)
  16. 	worker(c)
  17. 	t.End()
  19. 	time.Sleep(time.Second * 5)
  20. }
  22. func worker(c context.Context) {
  23. 	span, c := apm.StartSpan(c, "one", "test-type")
  25. 	e := apm.DefaultTracer().Recovered(errors.New("test-error"))
  26. 	e.SetSpan(span)
  27. 	e.Send()
  29. 	// do some work
  30. 	time.Sleep(time.Duration(rand.Intn(300-100)+300) * time.Millisecond)
  31. 	span.End()
  33. 	two(c)
  34. }
  36. func two(c context.Context) {
  37. 	span, _ := apm.StartSpan(c, "two", "test-type")
  38. 	// do some other work
  39. 	time.Sleep(time.Duration(rand.Intn(100-50)+100) * time.Millisecond)
  40. 	span.End()
  41. }
  • docker-compose.yaml to run APM locally
  1. version: '3.8'
  3. services:
  5.   apm-server:
  6.     image: docker.elastic.co/apm/apm-server:7.15.0
  7.     cap_add: ["CHOWN", "DAC_OVERRIDE", "SETGID", "SETUID"]
  8.     cap_drop: ["ALL"]
  9.     ports:
  10.     - 8200:8200
  11.     command: >
  12.        apm-server -e
  13.          -E apm-server.rum.enabled=true
  14.          -E setup.kibana.host=kibana:5601
  15.          -E setup.template.settings.index.number_of_replicas=0
  16.          -E apm-server.kibana.enabled=true
  17.          -E apm-server.kibana.host=kibana:5601
  18.          -E output.elasticsearch.hosts=["elasticsearch:9200"]
  19.     healthcheck:
  20.       interval: 10s
  21.       retries: 12
  22.       test: curl --write-out 'HTTP %{http_code}' --fail --silent --output /dev/null http://localhost:8200/
  23.     networks:
  24.       - elastic
  26.   elasticsearch:
  27.    container_name: elasticsearch
  28.    image: docker.elastic.co/elasticsearch/elasticsearch:7.15.0
  29.    ports:
  30.     - 9200:9200
  31.    environment:
  32.     - xpack.monitoring.enabled=true
  33.     - xpack.watcher.enabled=false
  34.     - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
  35.     - discovery.type=single-node
  36.    networks:
  37.     - elastic
  39.   kibana:
  40.    container_name: kibana
  41.    image: docker.elastic.co/kibana/kibana:7.15.0
  42.    ports:
  43.     - 5601:5601
  44.    depends_on:
  45.     - elasticsearch
  46.    environment:
  47.     - ELASTICSEARCH_URL=http://localhost:9200
  48.     - xpack.apm.enabled=false
  49.    networks:
  50.     - elastic
  52.   
  53. networks:
  54.   elastic:
  55.     driver: bridge

答案1

得分: 1

你的追踪器可能在作业退出之前没有发送事务。为了确保发送事务，可以在main()函数中的time.Sleep之后（或替换它）添加以下代码：

  1. apm.DefaultTracer().Flush(nil)
英文:

Your tracer is probably not sending the transaction before the job exits. To ensure it does, add after (or replace) the time.Sleep in main() with:

  1. apm.DefaultTracer().Flush(nil)

huangapple
  • 本文由 发表于 2022年9月26日 02:01:38
  • 转载请务必保留本文链接：https://go.coder-hub.com/73846719.html
  • apm
  • elastic-apm
  • elasticsearch
  • go
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定