Nameko HTTP file upload

config_client.yaml

WEB_SERVER_ADDRESS: 0.0.0.0:8001

config_server.yaml

WEB_SERVER_ADDRESS: 0.0.0.0:8002

hello.txt

world

Makefile

install:
	pip install -r requirements.txt

run_client:
	nameko run services:ClientService --config config_client.yaml

run_server:
	nameko run services:ServerService --config config_server.yaml

run:
	$(MAKE) -j2 run_client run_server

test:
	curl localhost:8001

requirements.txt

nameko==2.11.0

services.py

import json
import requests
from nameko.web.handlers import http


class ClientService:
    name = "client"
    server_url = "http://localhost:8002"

    @http("GET", "/")
    def upload_file(self, request):
        files = {"my_file": open("hello.txt", "rb")}
        response = requests.post(self.server_url, files=files)
        return response.text


class ServerService:
    name = "server"

    @http("POST", "/")
    def save_file(self, request):
        for file in request.files.items():
            _, file_storage = file
            file_storage.save(f"saved_{file_storage.filename}")
        return json.dumps({"ok": True})