microsoft / agogosml

agogosml is a flexible data processing pipeline that addresses the common need for operationalizing ML models at scale
MIT License
33 stars 16 forks source link

Add redis streaming client #250

Closed c-w closed 5 years ago

c-w commented 5 years ago

Integration tested via:

docker network create redis-test

docker build --target builder -t agogosml -f agogosml/Dockerfile.agogosml agogosml

docker run -d --name redis --rm --network redis-test -p 6379:6379 redis:5-alpine \
  redis-server --requirepass 123456password

docker run -d --rm --network redis-test -it agogosml \
  python -m agogosml.tools.receiver --receiver redis \
  '{"REDIS_URL":"redis://:123456password@redis:6379", "REDIS_CHANNEL":"mychan"}'

docker run -d --rm --network redis-test -it agogosml \
  python -m agogosml.tools.sender --infile README.rst --sender redis \
  '{"REDIS_URL":"redis://:123456password@redis:6379", "REDIS_CHANNEL":"mychan"}'

docker logs -f <id-of-receiver-container>

All Submissions: