이 글은 csv 같은 파일에 시계열 데이터를 순서대로 불러고 싶을 때 사용하는 Data publisher에 대한 설명한다.
1.Data Publisher Agent
- 데이터 퍼블리셔 에이전트(Data Publisher Agent) : 시계열 파일(csv 파일)과 같이 데이터를 순차적으로 메시지 버스로 보내고 싶을 때 사용하는 에이전트
2.실행방법
- 에이전트 실행할 때는 항상 볼트론이 실행되어 있어야 하고, Configuration이 정확하게 등록되어 있어야 한다.
- Configuration 경로가 모두 설정되어 있어야 한다.(파이참 > Run > Edit configuration)
- Name : publisher(에이전트를 실행할 때 이 문구가 보임)
- Script path : 설치한 볼트론의 pycharm-launch.py 가 있는 곳의 경로
- Parameters : Listener agent의 에이전트 파일(agent.py)가 있는 곳의 경로
- Environment variables : 환경 변수 설정
PYTHONBURRERED = 1
AGENT_CONFIG = 리스너 에이전트의 config 파일의 경로
AGENT_VIP_IDENTITY = platform.publisher (플랫폼 상에서 정체성을 부여)
- Working directory : 볼트론이 깔린 위치
3.어떤 파일을 불러올 것인가?
- configuration 파일을 어떻게 사용하는 것인가? configuration은 뭔가 값을 바꾸는 것을 편리하도록 돕는 파일을 말한다. 긴말 필요 없이 확인해보면 된다.
- input_data : csv 파일의 경로를 설정한다.
- publish_interval : 몇 초에 한번씩 값을 보낼 것인가?(실제 시간)
- 시계열 데이터 안에 시간 간격을 얼마로 설정할 것인가?
- max_data_frequency : 60 (1분 간격 시계열 데이터가 있으면, 60은 1분 씩 뽑는다. 900은 15분 간격으로 데이터 Publisher)
- 시계열 컬럼의 이름이 'Timestamp'인가? 맞으면 true 인 상태로 두면 된다
