anjakammer / rabbitmq-with-django Goto Github PK

• add state failed to task
• add signal to set the "failed" state, if retry/redelivery was made 3 times
  (https://hackernoon.com/designing-a-microservices-architecture-for-failure-a57f34ded646)
• think of handling the lack of ack for a task

Ipfs Python Client

IPFS Daemon

• start ipfs daemon on startup

OcrRequest

• mount volume for data storage
• init ipfs daemon in dockerfile command
• config ipfs to store files at /data directory with env var (IPFS_PATH=/path/to/ipfsrepo)
• add image on task creation
• save hash in task entry

OcrService

• get file content with ipfs cat and stream the data into the desired location (use env var for this )

• create list view with a creation of a task
• make image upload possible, but safe hash for #3
• render status of tasks with web-socket

• OcrWorker uses OcrService to process result

• Use python logging for logs
• find a solution to gather logs from containers

Because, the task was queued, but is not progressing yet. We actually do not know.

• create Controller
• persist ocrTasks -> send ocrRequest -> persist result

• Service takes image and extracts text from it
• OcrWorker uses Service/OcrService