Skip to content

Latest commit

 

History

History
89 lines (65 loc) · 1.91 KB

README.md

File metadata and controls

89 lines (65 loc) · 1.91 KB
Raw

replayman

Log agent to replay time-stamped log stream.

Getting started

Installation

cargo install replayman

Prepare for your data

TSV with a header line is supported.

curl -O https://raw.githubusercontent.com/SpringQL/dataset/main/pseudo-in-vehicle/AirConditioner-30sec.tsv

Usage

stdout

$ replayman \
  --timed-by Time \
  --initial-timestamp '2020-10-21T10:37:56.000+09:00' \
  AirConditioner-30sec.tsv

TCP socket

nc -l 19870
$ replayman \
  --timed-by Time \
  --initial-timestamp '2020-10-21T10:37:56.000+09:00' \
  --dest-tcp '127.0.0.1:19870' \
  AirConditioner-30sec.tsv

MQTT

Using mosquitto here for example.

mosquitto_sub -h 127.0.0.1 -t replayman/test
$ replayman \
  --timed-by Time \
  --initial-timestamp '2020-10-21T10:37:56.000+09:00' \
  --dest-mqtt '127.0.0.1:1883' \
  --dest-mqtt-topic 'replayman/test' \
  AirConditioner-30sec.tsv

Kafka

# create `replayman-test` topic
kafka-topics --create --bootstrap-server localhost:9092 --topic replayman-test --replication-factor 1 --partitions 1
# subscribe to `replayman-test` topic
kafka-console-consumer --bootstrap-server localhost:9092 --topic replayman-test --from-beginning
$ replayman \
  --timed-by Time \
  --initial-timestamp '2020-10-21T10:37:56.000+09:00' \
  --dest-kafka-bootstrap '127.0.0.1:9092' \
  --dest-kafka-topic 'replayman-test' \
  AirConditioner-30sec.tsv

License

Licensed under either of Apache License, Version 2.0 or MIT license at your option.

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in replayman by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

Copyright (c) 2021-2022 TOYOTA MOTOR CORPORATION.