Python Flask: Interacts with Docker Containers

import sys, json, os, requestsfrom textblob import TextBlobdef extract_nouns(text):    blob = TextBlob(text)    filtered_tags = list(filter(lambda tag: tag[1] == "NN", blob.tags))    nouns = list(map(lambda tag: tag[0], filtered_tags))    return nounsdef read_file(path):    with open(path) as f:        contents = f.read()    return contentsdef save_data(path, data):    with open(path, "w") as f:        json.dump(data, f)def get_filename_from_path(path):    return os.path.splitext(os.path.basename(path))[0]def notify_done(url, file_name):    requests.get(f"{url}/docker/tokenizer_done?file_name={file_name}")if __name__ == "__main__":    if len(sys.argv) < 4:        print("You must pass file path as an argument")        print("python3 main.py [file path to read] [dir to save] [notification api]")        print("Example) python3 main.py ./test.txt ./ http://host.docker.internal:20000")        sys.exit()    api_url = sys.argv[3]    file_path = sys.argv[1]    file_name = get_filename_from_path(file_path)    target_path = os.path.join(sys.argv[2], file_name + ".json")     text = read_file(file_path)    nouns = extract_nouns(text)    save_data(target_path, {"nouns": nouns})    notify_done(api_url, file_name)    print("Done")

import sys, json, os, requestsdef count_word(nouns_list):    count_dict = dict()    for noun in nouns_list:        if noun in count_dict:            count_dict[noun] += 1        else:            count_dict[noun] = 1    return count_dictdef load_data(path):    with open(path) as f:        json_data = json.load(f)    return json_datadef save_data(path, data):    with open(path, "w") as f:        json.dump(data, f)def get_filename_from_path(path):    return os.path.splitext(os.path.basename(path))[0]def notify_done(url, file_name):    requests.get(f"{url}/docker/word_count_done?file_name={file_name}")if __name__ == "__main__":    if len(sys.argv) < 4:        print("You must pass file path as an argument")        print("python3 main.py [file path to read] [dir to save] [notification api]")        print("Example) python3 main.py ./test.txt ./ http://host.docker.internal:20000")        sys.exit()    api_url = sys.argv[3]    file_path = sys.argv[1]    file_name = get_filename_from_path(file_path)    target_path = os.path.join(sys.argv[2], file_name + ".json")     json_data = load_data(file_path)    count_dict = count_word(json_data["nouns"])    save_data(target_path, {"result": count_dict})    notify_done(api_url, file_name)    print("Done")

FROM python:3.9WORKDIR /appCOPY . .RUN pip install pipenvRUN pipenv installRUN pipenv run python3 -m textblob.download_corporaENTRYPOINT ["pipenv", "run", "python3", "./main.py"]

FROM python:3.9WORKDIR /appCOPY . .RUN pip install pipenvRUN pipenv installENTRYPOINT ["pipenv", "run", "python3", "./main.py"]

from flask import Flaskfrom dotenv import load_dotenvload_dotenv()app = Flask(__name__)import routes

import osfrom flask import jsonify, requestfrom server import appfrom lib import docker, jsonresult = []@app.route('/docker/tokenizer_done')def get_tokenizer_done():    file_name = request.args.get("file_name")    docker.run_word_count_container(file_name)    return "run a word_count container"@app.route('/docker/word_count_done')def get_word_count_done():    file_name = request.args.get("file_name")    json_data = json.load_data(        os.path.join(os.getenv("SHARED_VOLUME_PATH"),        "word_count_output",        f"{file_name}.json"    ))    result.append(json_data)    return "all works done"@app.route('/docker/result')def get_result():    file_name = request.args.get("file_name")    return jsonify({        "result": result    })

import osfrom flask import jsonify, requestfrom werkzeug.utils import secure_filenamefrom server import appfrom lib import docker@app.route("/upload", methods=["POST"])def upload_file():    f = request.files["file"]    file_name = secure_filename(f.filename)    f.save(os.path.join(os.getenv("SHARED_VOLUME_PATH"), "input", file_name))    docker.run_tokenizer_container(file_name)    return "succeed to upload"

from routes import docker, upload

import osAPI_URL = os.getenv("API_URL")VOLUME_ROOT_PATH = os.getenv("SHARED_VOLUME_PATH")RUN_TOKENIZER_CONTAINER = 'docker run -it --add-host=host.docker.internal:host-gateway -v "' + VOLUME_ROOT_PATH + ':/shared_volume" hskcoder/tokenizer:0.2 /shared_volume/input/{FILE_NAME_WITH_EXTENSION} /shared_volume/tokenizer_output ' + API_URLRUN_WORD_COUNT_CONTAINER = 'docker run -it --add-host=host.docker.internal:host-gateway -v "' + VOLUME_ROOT_PATH + ':/shared_volume" hskcoder/word_count:0.2 /shared_volume/tokenizer_output/{FILE_NAME_WITHOUT_EXTENSION}.json /shared_volume/word_count_output ' + API_URLdef run_tokenizer_container(file_name):    print(RUN_TOKENIZER_CONTAINER.format(        FILE_NAME_WITH_EXTENSION = file_name    ))    os.popen(RUN_TOKENIZER_CONTAINER.format(        FILE_NAME_WITH_EXTENSION = file_name    ))def run_word_count_container(file_name):    os.popen(RUN_WORD_COUNT_CONTAINER.format(        FILE_NAME_WITHOUT_EXTENSION = file_name    ))

import jsondef load_data(path):    with open(path) as f:        json_data = json.load(f)    return json_data

API_URL=http://host.docker.internal:20000ROOT_PATH=C:\Users\hskco\OneDrive\ \stuff\docker\apiSHARED_VOLUME_PATH=C:\Users\hskco\OneDrive\ \stuff\docker\api\shared_volume

python3 -m pipenv run flask run -h 0.0.0.0 --port 20000

$env:FLASK_APP = './server.py'