florimondmanca / kafka-fraud-detector Goto Github PK

FROM python:3.6

WORKDIR /usr/app

ADD ./requirements.txt ./
RUN pip install -r requirements.txt
ADD ./ ./

CMD ["python", "app.py"]

# Dockerfile
FROM python:3.7

WORKDIR /usr/app

ADD ./requirements ./
RUN pip install -r requirements.txt
ADD ./app.py ./

CMD ["python", "app.py"]

docker exec kafkafrauddetector_broker_1 kafka-console-consumer --bootstrap-server localhost:9092 --topic streaming.transactions.legit

{"source": "uZxSDHD4wcE5", "target": "g0wgLDJftHBW", "amount": 150.45, "currency": "EUR"}
{"source": "3wiBuTZ9Sknw", "target": "r2UMsWnddfB4", "amount": 533.24, "currency": "EUR"}
{"source": "JgxFHAgwN8pj", "target": "YIEKjarfhMME", "amount": 273.84, "currency": "EUR"}
{"source": "UwpUOkML6rE0", "target": "lpth8JQQJYn3", "amount": 580.66, "currency": "EUR"}
{"source": "dqjbxgwsdJLV", "target": "JPmpzh2hiHzp", "amount": 152.41, "currency": "EUR"}
{"source": "tUb6sHBbbOnJ", "target": "wqyVub0ZnsuY", "amount": 91.31, "currency": "EUR"}
{"source": "1ljt52vUC2Aw", "target": "jHGOvGtbgW5E", "amount": 884.41, "currency": "EUR"}
{"source": "tpjFGUpeWE9y", "target": "rJ28GOX1OuRT", "amount": 874.21, "currency": "EUR"}
{"source": "vIhuz9ncvkev", "target": "1IiGlLtclgp8", "amount": 261.06, "currency": "EUR"}
{"source": "F7QziI9EksWS", "target": "jdz7KaaNbro1", "amount": 740.54, "currency": "EUR"}
{"source": "8PgQvfjGx7Ux", "target": "l6U6uHA9lp07", "amount": 502.15, "currency": "EUR"}
{"source": "EVqWKd9wRtjG", "target": "i3HHMtFfVmHK", "amount": 8.62, "currency": "EUR"}
{"source": "qreSXgRlSiDr", "target": "nVPkhU7gtcc9", "amount": 840.88, "currency": "EUR"}
{"source": "m6mmbKIBqEpI", "target": "010nHlF8WYj4", "amount": 282.72, "currency": "EUR"}