From daf750e89d76dad57845135127aaefa4396119e9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E2=80=9CNaeel=E2=80=9D?= <tazet@narod.ru>
Date: Mon, 9 Mar 2026 09:51:56 +0400
Subject: [PATCH] feat: notes-python CRUD example + runtime path/query
 forwarding

- invoke.go: forward sub-path and query string to function pods
- server.js v0.1.2: add _path, _query, _method to event
- server.py v0.1.1: add _path, _query, _method to event
- upload.go: bump runtime versions (nodejs20:v0.1.2, python3.11:v0.1.1)
- examples/notes-python: CRUD notes via sub-path routing
  - sql-runner: generic SQL executor for DDL jobs
  - notes: CRUD router (/add, /update, /delete)
  - notes-list: SELECT all notes
  - init.tf: create TABLE + INDEX on apply
---
 notes-python/code/notes-list/handler.py       |  22 ++++++
 notes-python/code/notes-list/requirements.txt |   1 +
 notes-python/code/notes/handler.py            |  74 ++++++++++++++++++
 notes-python/code/notes/requirements.txt      |   1 +
 notes-python/code/sql-runner/handler.py       |  26 ++++++
 notes-python/code/sql-runner/requirements.txt |   1 +
 notes-python/dist/notes-list.zip              | Bin 0 -> 746 bytes
 notes-python/dist/notes.zip                   | Bin 0 -> 1226 bytes
 notes-python/dist/sql-runner.zip              | Bin 0 -> 796 bytes
 notes-python/init.tf                          |  34 ++++++++
 notes-python/main.tf                          |  21 +++++
 notes-python/notes-list.tf                    |  32 ++++++++
 notes-python/notes.tf                         |  35 +++++++++
 notes-python/outputs.tf                       |  12 +++
 notes-python/sql-runner.tf                    |  26 ++++++
 notes-python/variables.tf                     |   9 +++
 16 files changed, 294 insertions(+)
 create mode 100644 notes-python/code/notes-list/handler.py
 create mode 100644 notes-python/code/notes-list/requirements.txt
 create mode 100644 notes-python/code/notes/handler.py
 create mode 100644 notes-python/code/notes/requirements.txt
 create mode 100644 notes-python/code/sql-runner/handler.py
 create mode 100644 notes-python/code/sql-runner/requirements.txt
 create mode 100644 notes-python/dist/notes-list.zip
 create mode 100644 notes-python/dist/notes.zip
 create mode 100644 notes-python/dist/sql-runner.zip
 create mode 100644 notes-python/init.tf
 create mode 100644 notes-python/main.tf
 create mode 100644 notes-python/notes-list.tf
 create mode 100644 notes-python/notes.tf
 create mode 100644 notes-python/outputs.tf
 create mode 100644 notes-python/sql-runner.tf
 create mode 100644 notes-python/variables.tf

diff --git a/notes-python/code/notes-list/handler.py b/notes-python/code/notes-list/handler.py
new file mode 100644
index 0000000..84a0cf4
--- /dev/null
+++ b/notes-python/code/notes-list/handler.py
@@ -0,0 +1,22 @@
+# 2026-03-09
+# handler.py — возвращает все записи из таблицы notes.
+# GET/POST /fn/default/notes-list → JSON массив записей, сортировка по created_at DESC.
+import os
+import psycopg2
+import psycopg2.extras
+
+
+def handle(event):
+    dsn = os.environ['PG_DSN']
+    conn = psycopg2.connect(dsn)
+    try:
+        cur = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
+        cur.execute(
+            "SELECT id, title, body, created_at::text FROM notes ORDER BY created_at DESC"
+        )
+        rows = cur.fetchall()
+        return [dict(r) for r in rows]
+    except Exception as e:
+        return {'error': str(e)}
+    finally:
+        conn.close()
diff --git a/notes-python/code/notes-list/requirements.txt b/notes-python/code/notes-list/requirements.txt
new file mode 100644
index 0000000..37ec460
--- /dev/null
+++ b/notes-python/code/notes-list/requirements.txt
@@ -0,0 +1 @@
+psycopg2-binary
diff --git a/notes-python/code/notes/handler.py b/notes-python/code/notes/handler.py
new file mode 100644
index 0000000..cce026f
--- /dev/null
+++ b/notes-python/code/notes/handler.py
@@ -0,0 +1,74 @@
+# 2026-03-09
+# handler.py — CRUD роутер для таблицы notes.
+# Роутинг по event._path (sub-path URL):
+#   POST /fn/default/notes/add?title=...&body=...    → INSERT
+#   POST /fn/default/notes/update?id=1&title=...     → UPDATE
+#   POST /fn/default/notes/delete?id=1               → DELETE
+# _path и _query добавляет runtime из HTTP запроса (server.py).
+import os
+import psycopg2
+import psycopg2.extras
+
+
+def handle(event):
+    dsn = os.environ['PG_DSN']
+    # sub-path без ведущего слэша: "add", "update", "delete"
+    action = event.get('_path', '/').strip('/')
+    q = event.get('_query', {})
+
+    conn = psycopg2.connect(dsn)
+    try:
+        cur = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
+
+        if action == 'add':
+            title = q.get('title') or event.get('title', '')
+            body = q.get('body') or event.get('body', '')
+            if not title:
+                return {'error': 'title is required'}
+            cur.execute(
+                "INSERT INTO notes (title, body) VALUES (%s, %s)"
+                " RETURNING id, title, body, created_at::text",
+                (title, body)
+            )
+            row = cur.fetchone()
+            conn.commit()
+            return dict(row)
+
+        elif action == 'update':
+            id_ = q.get('id') or event.get('id')
+            if not id_:
+                return {'error': 'id is required'}
+            title = q.get('title') or event.get('title', '')
+            body = q.get('body') or event.get('body', '')
+            cur.execute(
+                "UPDATE notes SET title=%s, body=%s WHERE id=%s"
+                " RETURNING id, title, body, created_at::text",
+                (title, body, int(id_))
+            )
+            row = cur.fetchone()
+            conn.commit()
+            return dict(row) if row else {'error': 'not found'}
+
+        elif action == 'delete':
+            id_ = q.get('id') or event.get('id')
+            if not id_:
+                return {'error': 'id is required'}
+            cur.execute(
+                "DELETE FROM notes WHERE id=%s RETURNING id",
+                (int(id_),)
+            )
+            row = cur.fetchone()
+            conn.commit()
+            return {'deleted': row['id']} if row else {'error': 'not found'}
+
+        else:
+            return {
+                'error': f'unknown action: /{action}',
+                'hint': 'use /add?title=...&body=..., /update?id=X&title=...&body=..., /delete?id=X'
+            }
+
+    except Exception as e:
+        conn.rollback()
+        return {'error': str(e)}
+    finally:
+        conn.close()
diff --git a/notes-python/code/notes/requirements.txt b/notes-python/code/notes/requirements.txt
new file mode 100644
index 0000000..37ec460
--- /dev/null
+++ b/notes-python/code/notes/requirements.txt
@@ -0,0 +1 @@
+psycopg2-binary
diff --git a/notes-python/code/sql-runner/handler.py b/notes-python/code/sql-runner/handler.py
new file mode 100644
index 0000000..2b39304
--- /dev/null
+++ b/notes-python/code/sql-runner/handler.py
@@ -0,0 +1,26 @@
+# 2026-03-09
+# handler.py — универсальный исполнитель SQL запросов.
+# Принимает event.statements — массив SQL строк, выполняет последовательно.
+# Используется sless_job для DDL операций (CREATE TABLE, миграции и т.д.)
+import os
+import psycopg2
+
+
+def handle(event):
+    dsn = os.environ['PG_DSN']
+    statements = event.get('statements', [])
+    if not statements:
+        return {'error': 'no statements provided'}
+
+    conn = psycopg2.connect(dsn)
+    try:
+        cur = conn.cursor()
+        for sql in statements:
+            cur.execute(sql)
+        conn.commit()
+        return {'ok': True, 'executed': len(statements)}
+    except Exception as e:
+        conn.rollback()
+        return {'error': str(e)}
+    finally:
+        conn.close()
diff --git a/notes-python/code/sql-runner/requirements.txt b/notes-python/code/sql-runner/requirements.txt
new file mode 100644
index 0000000..37ec460
--- /dev/null
+++ b/notes-python/code/sql-runner/requirements.txt
@@ -0,0 +1 @@
+psycopg2-binary
diff --git a/notes-python/dist/notes-list.zip b/notes-python/dist/notes-list.zip
new file mode 100644
index 0000000000000000000000000000000000000000..1e3b0367130cc3e103e500a5a5cd44a4521569bb
GIT binary patch
literal 746
zcmWIWW@Zs#-~d7f2E{HQ0S8<_Rz_l8N=|B#UO{Ed#QR;h{6vnw|18q}^$?3mm;Db%
z*8Ej3oieYx?$z|3SW<L}cZso4@upBO$Gs66d$nsPgb2KqzY}ipnd`U8(T!V^^8Ebv
z-T!=Y&ijxBS9AWx=l=`OxBIA7AbncJUDhw{gT;TYJ&$DbD^j1w-13k4bW5)>yzF51
z1K#O>4n*&Mp!;E(dBXIVPv-wlMpx(CH;1&SebFkA?3KFy_aTSW${dv$$6Wn*mtXsQ
zM!@D?edF`P|3p9N>%C3le{xl`{_Oqi1o1tai+4X+JNI*6_@8F)2kiG6FGvWhJ)W^Z
zoOk!a>3e5u_%1kee|zUlPSeWUR_~qXOzP`>Udg$ve%kkse5$Ou{0s_)LRJfWIzH)L
z_PQ6cUjO*shoN7$PHvr4{kP-xca0PNJv?(7zr0~6dgtVP{A|mj3vQYJ1CC|tc)W~!
z{wCrf!{a^EIbT^t7jSVEb}dr)(l7u0{857{!BY1Ls-_Eiiq;&Io_Z!rU2yB|mf)uJ
z=6|OT^E%dF=w|!y<!WW0xcis=_Ss+Wy(!lynW5Bq+v5CRVbPTrgz_f&OjytCF_n#X
zW=V4Ukpis(CxM-lG&wgi=FAti3kl3#x;ocjNiC0^mGi8V7U%t$O9P*sS|DGspP7N-
z|Nj7Qc8;HA&D@t585mA6F)#$+ObG(Olu(pfSejXsnwy$eQmj`}QKF@>&gY!IhxsMn
zQ)j$&Ry|>2fth(duHmN`PzOj?fHxzP2s0vmA=?K^Uofzw5yV2IHgtW+W`fLxfhCPx
ZK$oMtEx?<V4Wxnz2+M$U98e7d0|0}&Ab$V=

literal 0
HcmV?d00001

diff --git a/notes-python/dist/notes.zip b/notes-python/dist/notes.zip
new file mode 100644
index 0000000000000000000000000000000000000000..54023097c2f594e0e6471c7a3b7309aa54d7a9aa
GIT binary patch
literal 1226
zcmWIWW@Zs#-~d7f2E{HQ0S8<_Rz_l8N=|B#UP0xVu(w&#?jnEJFW+(E#%}J{Q(rqR
zWD<1R;>)ux=gUPlCxO><Z&sYBa+^1Et8UN1LWM0;f;4Iy?3(7d+(>w}=g=GNC!VLy
ztVvn>q~n|Wtuyjx-`uNycc=JVUmB~Kx!L~6`#-8`AKyO3^~POf=?wN}#TuLc%yL_+
zeNUXfn)}acf578EGFPfgC;w;r*($ZtyL9oo&*ne%9cCU;TCt|#*XEABVf8D^7uc<c
zKHxs%)B^jCCw4oOZbzGMj;p@CIy{Uap?vw})+ncJ4)wrkr)D{>cIB|0;IeFoAj`p9
za?Z}Sj0``1JS)GEReGqbJhINrVd4>fj;xxkW=9)6>+-k%+#s!Y+TG%)tKF3LbNOwz
z7oOZ+yE6NQeA*0tQ^)PEf_kq+`%aO1E`GpR>m(yv>DqM<Jh$)We&yABh28m$wkcD1
zLS0J4_a-h&2?M>x&XYL`ZHCf&Zp?{i|Kak<BScHIWwMjy^$BmUYFEwo2*_X%W?bgp
zV*KmO&DuNpWl`sfKUc9XOIqP=8Wz6b-l~mN^Y@>t4@>^)ch~8k*WD-kpV_YrlwBq0
z6e_=JTDa|Io>1Nh5${7KmaD&U>%<-pc>LqR6&ZbjNs}8_FIW3lpm$}$^B)CO&q941
z&a7ygZMOQl#WX#kD@q=ATXJW;=y5*$gr)Ep>*IBQU#bV{NXnZ%^WeT^;Wb-jTE9<3
zU@-qApX$s8VZ|qRLJd>5PF=v*UiLWcWyOIXIo97+^7~zUo01`Z|LLo%POB<+%<vTY
zJMreLr@Su@Zaibr8q8jNZbvZtZe|503%fHM$4^*lryiB$|G?R2+<BLE$Ev@(5>{Wm
zyYar+4z>&CvK1c=AATEmgRwmH#|EuEuaua!9L`&R_g0oITT{)9liw7dSxl1nsvNoA
zyGCjCKc~8tF)wo~kKWvP&GxZlQ|g}c8fB*$uL-?*&~Rd>Ics{ykxNhCR2*Zn(4Bq2
zs_q;+%h&f)R5Bdh|Guze<$U#D_%BD4(!Kvr4nCc?Q9Ubhy5EhhyK^$SXB@5$J<#ue
zsEmWfH0<c}tv&oLUeg!s`z}Azef8>x1zI20^hAAZNe$8d;aPvP_zU-^>qQIS#>>}S
zzxQ)rK(*WTNgdx;ng|~Izvt8(u{BD|*Ik^Kxo_V5zuq&C+zGTk822KpYl?+rt>;Zc
z-7jmM-(ER)ZjP(boLZ-)>*jOv%-`|hhe7e=%3Wpo2kwSGT^XzuRMPC9WHUivmi*gY
z9tV7~+kDPlD$(zXKX+m011ZIw-L|i%wp`HgZ7<d+Jk@gT)q7yh{r^9}o1G)j|Gm;C
zW(J0EU}g@$nbQS;>WfkfOEZg7b5rw5iuFn=O0+cA`JB`DFu&w`>WsI}swYe=Ff*^m
zHT)C<>Hz5q@MdHZVMdf6$o7HC4;Wa|2x1{h6LfvZW`fLxfhCQvfUZY(TYxt!8%PBc
N5S9UHJD}Sb7yv%a8SMZ7

literal 0
HcmV?d00001

diff --git a/notes-python/dist/sql-runner.zip b/notes-python/dist/sql-runner.zip
new file mode 100644
index 0000000000000000000000000000000000000000..b684fdd65a10ad88487bf655a57212f82318e1ce
GIT binary patch
literal 796
zcmWIWW@Zs#-~d7f2E{HQ0S8<_Rz_l8N=|B#UO{Ef1jnq~4kB&et&TS9s5B}!akonC
z@yNd1tC{;amgC^WV=JX9-DXP8o*}eB=7kz#{;n76!VT8>PT93>{fB#^Rg;X8PnUUb
zndtWa&;RfH%Nd?7{&f2AV)1tO^>dhiTzM3DC}qO8hvy$iUy#)^IL>)4!$GpI(2sw|
zg6bNkGn$7*^$PRWT@XljYnjZ?d%#`haTnW;B|OtDIOi}QkT*GSXW8FlhUYRk)*Ro#
zHzhCgT4Id0w~1Ej6v<V*i+kGCxay}esF%bWWTrTunP@cUG0*b0*2jyu^a?Uh-tS)Y
zrJ=thJ!i^Aj*vrBtp4lhF)X)OE_fx2_kilUGg~Z{t)KB&xFX-~TL0|Q47vSzSG<?S
z_t|f+;+w(D%RGl|pKy7QqA5pc&C*r!U0*i6vG6-`YxdKsvb_C|7#Li-oJCu>B;Fql
z`Vjp6@9odGPFjCIbE^9E%Diu-C$~I*_iwkVh3)6JPj~Rfys$kll_+<zB)sUyBO}e$
z672^?8|CMDUF=pC+qu2(YfIDYIM@FN=0vX8>+#Xl`}99O+c#b-qWlHQmI__^yge$~
zBj7sckv}(+q^l3)MclZ0CiwcvbG!XS=K8JqF0_4fhxT?R-<zqb1?K-wtaUiFW4rUu
z?blA^IZex2aXVbcVvERzQ~OmkCp}pt8fSZ4>)Wy|Uv8*vmi-(y>C1m_PT_?!o?F*5
zGcf%BAK=Z-@#pAeXBH*~hDe}D0M4`{08BeYsfDGPMX9-|c_qbqB^4!F8tZ({>3f)8
z@;!CNTW8f1CKi~P*W(&~iUD<ibOm@bGKnxFQY5l{pcDxMOBz8eMEXS6hioRuTo_o=
bXajUTy4wQ0S=m4;n1HYhNKXK&VPF6N_X{}C

literal 0
HcmV?d00001

diff --git a/notes-python/init.tf b/notes-python/init.tf
new file mode 100644
index 0000000..a76760f
--- /dev/null
+++ b/notes-python/init.tf
@@ -0,0 +1,34 @@
+# 2025-06-05
+# init.tf — джобы инициализации БД: создание таблицы + индекса.
+# Запускаются один раз при terraform apply.
+# Для повторного запуска (например после drop) — увеличь run_id.
+
+resource "sless_job" "create_table" {
+  namespace        = "default"
+  name             = "notes-create-table"
+  function         = sless_function.sql_runner.name
+  wait_timeout_sec = 120
+  run_id           = 1
+
+  event_json = jsonencode({
+    statements = [
+      "CREATE TABLE IF NOT EXISTS notes (id serial PRIMARY KEY, title text NOT NULL, body text, created_at timestamp DEFAULT now())"
+    ]
+  })
+}
+
+resource "sless_job" "create_index" {
+  depends_on = [sless_job.create_table]
+
+  namespace        = "default"
+  name             = "notes-create-index"
+  function         = sless_function.sql_runner.name
+  wait_timeout_sec = 60
+  run_id           = 1
+
+  event_json = jsonencode({
+    statements = [
+      "CREATE INDEX IF NOT EXISTS notes_created_idx ON notes(created_at DESC)"
+    ]
+  })
+}
diff --git a/notes-python/main.tf b/notes-python/main.tf
new file mode 100644
index 0000000..5f5e71f
--- /dev/null
+++ b/notes-python/main.tf
@@ -0,0 +1,21 @@
+# 2025-06-05
+# main.tf — terraform{} + provider для notes-python примера.
+# Ресурсы вынесены в отдельные .tf файлы.
+
+terraform {
+  required_providers {
+    sless = {
+      source  = "terra.k8c.ru/naeel/sless"
+      version = "~> 0.1.7"
+    }
+    archive = {
+      source  = "hashicorp/archive"
+      version = "~> 2.0"
+    }
+  }
+}
+
+provider "sless" {
+  endpoint = "https://sless-api.kube5s.ru"
+  token    = "dev-token-change-me"
+}
diff --git a/notes-python/notes-list.tf b/notes-python/notes-list.tf
new file mode 100644
index 0000000..2dc4fcf
--- /dev/null
+++ b/notes-python/notes-list.tf
@@ -0,0 +1,32 @@
+# 2025-06-05
+# notes-list.tf — функция для получения всех записей из таблицы notes.
+# GET или POST /fn/default/notes-list → JSON массив всех записей, сортировка по дате (новые первые).
+
+data "archive_file" "notes_list" {
+  type        = "zip"
+  source_dir  = "${path.module}/code/notes-list"
+  output_path = "${path.module}/dist/notes-list.zip"
+}
+
+resource "sless_function" "notes_list" {
+  namespace   = "default"
+  name        = "notes-list"
+  runtime     = "python3.11"
+  entrypoint  = "handler.handle"
+  memory_mb   = 128
+  timeout_sec = 30
+
+  env_vars = {
+    PG_DSN = var.pg_dsn
+  }
+
+  code_path = data.archive_file.notes_list.output_path
+  code_hash = filesha256("${path.module}/code/notes-list/handler.py")
+}
+
+resource "sless_trigger" "notes_list_http" {
+  namespace = "default"
+  name      = "notes-list-http"
+  type      = "http"
+  function  = sless_function.notes_list.name
+}
diff --git a/notes-python/notes.tf b/notes-python/notes.tf
new file mode 100644
index 0000000..9d0cb64
--- /dev/null
+++ b/notes-python/notes.tf
@@ -0,0 +1,35 @@
+# 2025-06-05
+# notes.tf — CRUD функция для таблицы notes.
+# Роутинг по sub-path URL:
+#   POST /fn/default/notes/add?title=...&body=...        → INSERT записи
+#   POST /fn/default/notes/update?id=1&title=...&body=... → UPDATE записи
+#   POST /fn/default/notes/delete?id=1                   → DELETE записи
+
+data "archive_file" "notes" {
+  type        = "zip"
+  source_dir  = "${path.module}/code/notes"
+  output_path = "${path.module}/dist/notes.zip"
+}
+
+resource "sless_function" "notes" {
+  namespace   = "default"
+  name        = "notes"
+  runtime     = "python3.11"
+  entrypoint  = "handler.handle"
+  memory_mb   = 128
+  timeout_sec = 30
+
+  env_vars = {
+    PG_DSN = var.pg_dsn
+  }
+
+  code_path = data.archive_file.notes.output_path
+  code_hash = filesha256("${path.module}/code/notes/handler.py")
+}
+
+resource "sless_trigger" "notes_http" {
+  namespace = "default"
+  name      = "notes-http"
+  type      = "http"
+  function  = sless_function.notes.name
+}
diff --git a/notes-python/outputs.tf b/notes-python/outputs.tf
new file mode 100644
index 0000000..d14f579
--- /dev/null
+++ b/notes-python/outputs.tf
@@ -0,0 +1,12 @@
+# 2025-06-05
+# outputs.tf — URL эндпоинтов для notes-python примера.
+
+output "notes_url" {
+  value       = sless_trigger.notes_http.url
+  description = "Базовый URL CRUD: /add?title=...&body=..., /update?id=X&title=...&body=..., /delete?id=X"
+}
+
+output "notes_list_url" {
+  value       = sless_trigger.notes_list_http.url
+  description = "URL для получения всех записей (GET или POST)"
+}
diff --git a/notes-python/sql-runner.tf b/notes-python/sql-runner.tf
new file mode 100644
index 0000000..fe5a56c
--- /dev/null
+++ b/notes-python/sql-runner.tf
@@ -0,0 +1,26 @@
+# 2025-06-05
+# sql-runner.tf — универсальная функция для выполнения SQL запросов.
+# Используется джобами для DDL операций (CREATE TABLE, индексы, миграции).
+# event.statements — массив SQL строк, выполняются последовательно в одной транзакции.
+
+data "archive_file" "sql_runner" {
+  type        = "zip"
+  source_dir  = "${path.module}/code/sql-runner"
+  output_path = "${path.module}/dist/sql-runner.zip"
+}
+
+resource "sless_function" "sql_runner" {
+  namespace   = "default"
+  name        = "sql-runner"
+  runtime     = "python3.11"
+  entrypoint  = "handler.handle"
+  memory_mb   = 128
+  timeout_sec = 30
+
+  env_vars = {
+    PG_DSN = var.pg_dsn
+  }
+
+  code_path = data.archive_file.sql_runner.output_path
+  code_hash = filesha256("${path.module}/code/sql-runner/handler.py")
+}
diff --git a/notes-python/variables.tf b/notes-python/variables.tf
new file mode 100644
index 0000000..d0ffeb4
--- /dev/null
+++ b/notes-python/variables.tf
@@ -0,0 +1,9 @@
+# 2025-06-05
+# variables.tf — входные переменные для notes-python примера.
+
+variable "pg_dsn" {
+  description = "PostgreSQL DSN для подключения к БД внутри кластера"
+  type        = string
+  default     = "postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable"
+  sensitive   = true
+}