Mlops, Airflow, Rabbitmq, Elasticsearch, Filebeat.
real-time data process. Inside our DAG we will have 2 tasks: An image to Base64 encoder and a prediction script that contains our trained machine learning model. The prediction script will depend on the encoder script running before it, so that it doesn’t try to predict without a Base64 formatted