replayman

时间戳日志流回放代理。

入门

安装

cargo install replayman

准备您的数据

支持带有标题行的TSV。

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

用法

标准输出

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

TCP套接字

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

例如，在此处使用mosquitto。

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

许可证

根据您的选择，许可在Apache License，版本2.0或MIT许可证下。

除非您明确表示，否则任何有意提交到replayman的贡献，根据Apache-2.0许可证的定义，应按照上述方式双重许可，不附加任何额外条款或条件。

版权（c）2021-2022 丰田汽车公司。