docker 위에 telegraf, influxdb(2.x) 컨테이너 올려서 mqtt 센서 데이터 수집하기

✅ influxdb 컨테이너 실행

도커 볼륨 설정을 위해 호스트 홈 디렉토리에 `influxdb-config`라는 디렉토리를 미리 만들어두고, (꼭 미리 만들 필요는 없다)

아래 명령어로 influxdb 컨테이너를 생성해 실행시켜주었다.

docker run -d --name influxdb -v ./influxdb-config/var/lib/influxdb:/var/lib/influxdb -v ./influxdb-config/etc/influxdb/influxdb.conf:/etc/influxdb/influxdb.conf -v ./influxdb-config/etc/initdb.d:/docker-entrypoint-initdb.d -p 8086:8086 influxdb

 

✅ influxdb 초기 설정

localhost:8086 접속하면 다음과 같이 influxdb 초기 설정 화면이 나온다.

 

계정 정보와 조직 이름, 버킷 이름을 입력해준다.

 

초기 설정이 완료되면, superuser 권한을 가진 API 토큰이 생성된다.

이 API 토큰을 잘 복사해두어야 한다.

 

 

✅ telegraf 설정파일 만들기

 

위에서 설정한 정보들을 가지고 `telegraf.conf` 를 작성해준다.

 

~/telegraf-config/telegraf.conf

# Global Agent Configuration
[agent]
  interval = "10s"
  round_interval = true
  metric_batch_size = 1000
  metric_buffer_limit = 10000
  collection_jitter = "0s"
  flush_interval = "10s"
  flush_jitter = "0s"
  precision = ""
  debug = false
  quiet = false
  logfile = ""

# MQTT Input Plugin Configuration
[[inputs.mqtt_consumer]]
  servers = ["tcp://192.168.70.203:1883"]
  topics = ["#"]
  qos = 0
  connection_timeout = "30s"
  data_format = "json"

# InfluxDB Output Plugin Configuration
[[outputs.influxdb_v2]]
  urls = ["http://localhost:8086"] # 만약 잘 안 되면, ip를 직접 입력하면 되기도 한다.
  token = "{API 토큰}"
  organization = "{organization 이름}"
  bucket = "{bucket 이름}"
  precision = "s"

 

mqtt_consumer server 정보에는 미리 올려둔 mqtt broker 주소를 적어주고,

influxdb 설정에는 아까 복사해두었던 API 토큰과, organization 이름, bucket 이름을 적어준다.

 

✅ telegraf 컨테이너 실행

설정파일을 저장하고, telegraf 컨테이너도 생성하여 실행시켜준다.

 

마찬가지로 도커 볼륨 설정을 위해 홈 디렉토리에 telegraf-config 디렉토리를 만들어주고,

홈 디렉토리에서 아래 명령어를 이용하여 telegraf 컨테이너를 만들어 실행시켜준다.

docker run -d --name telegraf -v ./telegraf-config/telegraf.conf:/etc/telegraf/telegraf.conf:ro telegraf

 

 

✅ 수집 데이터 확인

브라우저에서 다시 localhost:8086에 접속하여

아까 만들어둔 버킷을 선택하고 쿼리를 만들어 submit하면

mqtt 브로커로부터 수집한 데이터를 확인할 수 있다!

 

현재는 브로커로부터 오는 모든 데이터를 하나의 버킷에 무지성으로 밀어넣고 있지만,

telegraf.conf 파일에 세밀한 설정을 추가로 해준다면 데이터를 가공하기 더 편할 것이다.