clearml-server/fileserver/fileserver.py

69 lines
2.0 KiB
Python
Raw Normal View History

2019-06-10 21:24:35 +00:00
""" A Simple file server for uploading and downloading files """
import json
import os
from argparse import ArgumentParser
from pathlib import Path
from flask import Flask, request, send_from_directory, safe_join
2019-07-17 15:16:43 +00:00
from flask_compress import Compress
from flask_cors import CORS
2019-06-10 21:24:35 +00:00
2019-07-17 15:16:43 +00:00
from config import config
2019-06-10 21:24:35 +00:00
app = Flask(__name__)
2019-07-17 15:16:43 +00:00
CORS(app, **config.get("fileserver.cors"))
Compress(app)
2019-06-10 21:24:35 +00:00
@app.route("/", methods=["POST"])
def upload():
results = []
for filename, file in request.files.items():
if not filename:
continue
file_path = filename.lstrip(os.sep)
target = Path(safe_join(app.config["UPLOAD_FOLDER"], file_path))
target.parent.mkdir(parents=True, exist_ok=True)
file.save(str(target))
results.append(file_path)
return (json.dumps(results), 200)
@app.route("/<path:path>", methods=["GET"])
def download(path):
2019-07-17 15:16:43 +00:00
response = send_from_directory(app.config["UPLOAD_FOLDER"], path)
if config.get("fileserver.download.disable_browser_caching", False):
headers = response.headers
headers["Pragma-directive"] = "no-cache"
headers["Cache-directive"] = "no-cache"
headers["Cache-control"] = "no-cache"
headers["Pragma"] = "no-cache"
headers["Expires"] = "0"
return response
2019-06-10 21:24:35 +00:00
def main():
parser = ArgumentParser(description=__doc__)
parser.add_argument(
"--port", "-p", type=int, default=8081, help="Port (default %(default)d)"
)
parser.add_argument(
"--ip", "-i", type=str, default="0.0.0.0", help="Address (default %(default)s)"
)
parser.add_argument("--debug", action="store_true", default=False)
parser.add_argument(
"--upload-folder",
"-u",
default="/mnt/fileserver",
help="Upload folder (default %(default)s)",
)
args = parser.parse_args()
app.config["UPLOAD_FOLDER"] = args.upload_folder
app.run(debug=args.debug, host=args.ip, port=args.port, threaded=True)
if __name__ == "__main__":
main()