feat: python3.11 base runtime image + DockerHub registry support
- runtimes/python3.11/: Dockerfile + server.py (HTTP wrapper на :8080) - builder.go: RegistrySecret field, volume mount docker-creds для kaniko, убран --skip-tls-verify - config.go: добавлен RegistrySecret (env REGISTRY_SECRET, default sless-registry-auth) - main.go: передаём RegistrySecret в builder.Config - hack/create-registry-secret.sh: создаёт k8s Secret из DockerHub токена Образ наружу: naeel/sless-runtime-python3.11:latest (DockerHub) K8s secret: sless-registry-auth в namespace sless
This commit is contained in:
@@ -0,0 +1,15 @@
|
||||
# Изменено: 2026-03-07
|
||||
# Base runtime image для Python 3.11 serverless функций.
|
||||
# Содержит только HTTP-обёртку (server.py).
|
||||
# Пользовательский код докапывается kaniko поверх этого образа: COPY . /app/function/
|
||||
# Почему slim: минимальный размер образа, стандартная библиотека Python не нужна доп. пакетов.
|
||||
|
||||
FROM python:3.11-slim
|
||||
|
||||
WORKDIR /app
|
||||
|
||||
COPY server.py /app/server.py
|
||||
|
||||
EXPOSE 8080
|
||||
|
||||
CMD ["python", "/app/server.py"]
|
||||
@@ -0,0 +1,67 @@
|
||||
#!/usr/bin/env python3
|
||||
# Изменено: 2026-03-07
|
||||
# HTTP-обёртка для serverless функций на Python 3.11.
|
||||
# Загружает handler.py из /app/function/ и вызывает handle(event) на каждый запрос.
|
||||
# Почему importlib: нужно загружать модуль из фиксированного пути вне sys.path.
|
||||
|
||||
import sys
|
||||
import json
|
||||
import importlib.util
|
||||
from http.server import HTTPServer, BaseHTTPRequestHandler
|
||||
|
||||
HANDLER_PATH = "/app/function/handler.py"
|
||||
PORT = 8080
|
||||
|
||||
|
||||
def load_handler():
|
||||
# Загружаем модуль пользователя динамически — путь известен только в runtime.
|
||||
spec = importlib.util.spec_from_file_location("handler", HANDLER_PATH)
|
||||
module = importlib.util.module_from_spec(spec)
|
||||
spec.loader.exec_module(module)
|
||||
if not hasattr(module, "handle"):
|
||||
raise AttributeError(f"handler.py must define a 'handle(event)' function")
|
||||
return module.handle
|
||||
|
||||
|
||||
_handle = load_handler()
|
||||
|
||||
|
||||
class FunctionHandler(BaseHTTPRequestHandler):
|
||||
def log_message(self, format, *args):
|
||||
# Логи в stderr чтобы не мешать stdout
|
||||
sys.stderr.write("%s - [%s] %s\n" % (
|
||||
self.address_string(),
|
||||
self.log_date_time_string(),
|
||||
format % args,
|
||||
))
|
||||
|
||||
def do_GET(self):
|
||||
if self.path == "/health":
|
||||
self._respond(200, {"status": "ok"})
|
||||
else:
|
||||
self._respond(200, _handle({}))
|
||||
|
||||
def do_POST(self):
|
||||
length = int(self.headers.get("Content-Length", 0))
|
||||
body = self.rfile.read(length)
|
||||
try:
|
||||
event = json.loads(body) if body else {}
|
||||
except json.JSONDecodeError:
|
||||
# Если тело не JSON — передаём как строку, не ломаем вызов
|
||||
event = {"body": body.decode("utf-8", errors="replace")}
|
||||
result = _handle(event)
|
||||
self._respond(200, result)
|
||||
|
||||
def _respond(self, status, data):
|
||||
body = json.dumps(data).encode("utf-8")
|
||||
self.send_response(status)
|
||||
self.send_header("Content-Type", "application/json")
|
||||
self.send_header("Content-Length", str(len(body)))
|
||||
self.end_headers()
|
||||
self.wfile.write(body)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
server = HTTPServer(("0.0.0.0", PORT), FunctionHandler)
|
||||
print(f"sless runtime (python3.11) listening on :{PORT}", flush=True)
|
||||
server.serve_forever()
|
||||
Reference in New Issue
Block a user