docker-compose for the worker and Simple CLI

FROM kontr2/base-pipenv

ADD . /app

WORKDIR /app

EXPOSE 5000

ONBUILD COPY Pipfile Pipfile

ONBUILD COPY Pipfile.lock Pipfile.lock

CMD ["gunicorn", "--bind", "0.0.0.0:5000", "--workers", "3", "app:app"]

$ sudo docker network create --internal --subnet 10.1.1.0/24 internal-network

----

== Endpoints

Simple description of the endpoints used in the Worker

import logging

import worker.logging as logging_config

from worker import create_app

import kontr_worker.logging as logging_config

from kontr_worker import create_app

logging_config.load_config()

def get_celery():

    from kontr_worker.extensions import context

    return context.celery

log = logging.getLogger(__name__)

app = create_app()

celery = get_celery()

if __name__ == '__main__':

    pass

# Example: https://github.com/mattkohl/docker-flask-celery-redis/blob/master/docker-compose.yml

version: '3'

services:

    kontr-worker:

        build: .

        privileged: true

        command: >

            gunicorn -b 0.0.0.0:8000

              --access-logfile -

              --reload

              "app:app"

        ports:

        - "5000:5000"

        environment:

            WORKER_NAME: 'default-worker'

            SECRET_KEY: 'you-will-never-guess'

            INTERNAL_DOCKER_NETWORK: 'internal-network'

            CELERY_BROKER_URL: 'redis://redis:6379/1'

        depends_on:

        - redis

    redis:

        image: "redis:alpine"

    celery:

        build: .

        command: celery kontr_worker -l info -A app.celery

        environment:

            WORKER_NAME: 'default-worker'

            SECRET_KEY: 'you-will-never-guess'

            INTERNAL_DOCKER_NETWORK: 'internal-network'

            CELERY_BROKER_URL: 'redis://redis:6379/1'

        depends_on:

        - redis

import os

from flask import Flask

from worker import rest, async_celery, extensions

from worker.config import CONFIGURATIONS

from worker.tools.paths import ROOT_DIR

from kontr_worker import rest, async_celery, extensions

from kontr_worker.config import CONFIGURATIONS

from kontr_worker.tools.paths import ROOT_DIR

log = logging.getLogger(__name__)