HU
Az Eco² földgömbfigurája, a legújabb hivatalos főszereplőből e portfólió számára finomítva: égszínkék földgömb zöld szárazfölddel, a tetején csírával, barna mosolygó arccal
Vissza a terembe

Eco²

Backend · Cloud infrastructure

Újrahasznosítási útmutatás egy fotóból és egy beszélgetésből.

Mindent egyben AI-asszisztens, amely érti a koreai újrahasznosítás rendjét.

2025.10.31 — 2026.02.10

Csapatprojekt · infrastruktúra- és telepítési alapok → domain-backend → aszinkron feldolgozás, párbeszédes ágens, ellenőrzés

2025 새싹 해커톤 (Saessak Hackathon)Kiválósági díj · 2025. december 2.

  • WebalkalmazásMegszűnt szolgáltatás

Hogyan kapcsolódik ténylegesen a 24 csomópont, folyamatonként.

Saját üzemeltetésű Kubernetes, kubeadm-mel építve. A térkép a 24 fizikai csomópontot és a rajtuk futó munkaterheléseket a README öt rétegébe helyezi, és tényleges kapcsolataikkal köti össze. Egy folyamat kiválasztásakor csak annak útvonala emelődik ki, számozott lépésekkel.

Fotóról azonosítja a hulladékot, és elmagyarázza, hogyan kell kidobni, beszélgetés közben pedig helyekre, időjárásra, újrahasznosítási árakra és webes keresésre szolgáló eszközöket hív, és képeket generál. Ebben a csapatprojektben a klaszter- és telepítési alapokkal kezdtem, majd feladatköröm kiterjedt a domain-backendre, az aszinkron feldolgozásra, a párbeszédes ágensre és az ellenőrzésre.

A versenyfejlesztéstől a backend és az üzemeltetés megerősítéséig

A szolgáltatás működése véget ért; egy rögzített demó és a műszaki jelentés mutatja működés közben.

Klaszterkapcsolati térkép · újrarajzolva az a072127 commit manifestjeiből és kódjából
Eco² klaszterkapcsolati térkép · 24 csomópontA 24 fizikai csomópont térképe a README öt rétegsávjában. A böngésző csak a nevet kérdezi le a Route 53-ban; miután a TLS a 443-as porton az ALB-nél véget ér, egy NodePorton lévő Istio ingress Envoy továbbítja a kérést egy domain-API-hoz. A Scan API a RabbitMQ-ra teszi a munkát, és azonnal visszaad egy job_id-t; az AI-készletben futó scan-worker XADD-del előrehaladási eseményeket ír a Redis Streamsbe. Az Event Router beolvassa őket, frissíti a State KV-t, és a Pub/Sub-ra publikál, az SSE Gateway pedig elküldi őket a böngészőnek. A checkpoint-syncer tárolja a Chat ellenőrzőpontjait, a Chat-csomóponton futó persistence consumer pedig a PostgreSQL-ben tárolja az üzeneteket. A Platform Layer nem kérésútvonal; konfigurál, skáláz és megfigyel.BöngészőHTTPS · SSEAWS ALB443 · itt ér véget a TLSRoute 53DNSGitHub Actions · Docker Hubkonténerkép · manifest-revízióLLM APIOpenAI · GoogleLangSmithLLM-futtatások nyomkövetéseFluent BitDaemonSet · minden csomópontonk8s-masterALB Controller · ExternalDNSArgo CD image updaterIstiodcontrol planek8s-ingress-gatewayIstio ingress Envoyk8s-api-scanScan APIk8s-api-chatChat APImessage consumerpersistence consumerk8s-api-authauth APIext-authzk8s-api-infoInfo APIinfo-workerk8s-api-charactercharacter APIk8s-api-imageimages APIk8s-api-usersusers APIk8s-api-locationlocation APIk8s-sse-gatewaySSE Gatewayk8s-event-routerEvent Routerk8s-rabbitmqRabbitMQk8s-worker-aik8s-worker-ai-2k8s-worker-storagek8s-worker-storage-2k8s-redis-pubsubPub/Subk8s-redis-streamsStreamsState KVk8s-redis-cacheCachek8s-postgresqlPostgreSQLk8s-redis-authblacklistk8s-monitoringKEDAPrometheusGrafanaAlertmanagerk8s-loggingElasticsearchKibanascan-workerchat-workercheckpoint-syncerauth-relayauth-workerusers-workercharacter-workercharacter-match-workerKialiJaeger · dev in-memoryKubernetes-klaszter24 csomópont · kubeadmEdge Layer1 csomópontService Layer8 csomópont · Envoy sidecarIntegration Layer7 csomópontPersistence Layer5 csomópontPlatform Layer3 csomópont · konfigurálás · skálázás · megfigyelésAWS által felügyeltAI-készletdomain: worker-aitárolókészletdomain: worker-storageNincs rögzített csomópont1DNS-lekérdezés2 HTTPS 443 · Böngésző → AWS ALB23HTTP · NodePort4VirtualService5Celery-feladat6 consume · RabbitMQ → scan-worker67 HTTPS · AI-készlet → LLM API78XADD scan:events9XREADGROUP10SETEX state11PUBLISH12SUBSCRIBE13SSE-stream14Helyreállítás újracsatlakozáskor1 HTTPS 443 · Böngésző → AWS ALB12HTTP · NodePort3VirtualService4Taskiq-feladat5 consume · RabbitMQ → chat-worker56 HTTPS · AI-készlet → LLM API67XADD chat:events8XREADGROUP9PUBLISH10SUBSCRIBE11SSE-stream12checkpoint13ellenőrzőpont olvasása14szinkronizálás PostgreSQL-be15chat-persistence group16üzenetek mentése1DNS-lekérdezés2 HTTPS 443 · Böngésző → AWS ALB23HTTP · NodePort4ext-authz · gRPC 500515tiltólista-lekérdezés6VirtualService7gRPC8gRPC1outbox:blacklist2blacklist.events3 blacklist.events · RabbitMQ → auth-worker34tiltólista tárolása5 Celery batch · RabbitMQ → users-worker56UPSERT1konténerkép · manifest-revízió2Ingress → ALB · DNS-rekordok3xDS-konfiguráció4podszám5 podszám · KEDA → tárolókészlet56naplók7 LLM-futtatások nyomkövetése · AI-készlet → LangSmith7

Scan-kérés → élő kézbesítés

Egy fotóelemzési kérésből sorba állított munka lesz, és előrehaladási eseményei ugyanahhoz a böngészőhöz térnek vissza.

  1. BöngészőDNS-lekérdezésRoute 53

    Csak a név oldódik fel a Route 53-rekordokból. A kérések nem haladnak át a DNS-en.

  2. BöngészőHTTPS 443AWS ALB

    A TLS az ALB-nél ér véget.

  3. AWS ALBHTTP · NodePortIstio ingress Envoyk8s-ingress-gateway

    Az EC2-példány célpontjának NodePortján keresztül jut az Istio ingress Envoyhoz.

  4. Istio ingress Envoyk8s-ingress-gatewayVirtualServiceScan APIk8s-api-scan

    A Scan API-hoz irányítva, amely sorba állítja a munkát, és azonnal visszaad egy job_id-t; az eredmény lekérdezése 202-t ad vissza, amíg a feladat el nem készül.

  5. Scan APIk8s-api-scanCelery-feladatRabbitMQk8s-rabbitmq

    A Scan-feladat a RabbitMQ-ra kerül.

  6. RabbitMQk8s-rabbitmqconsumescan-workerk8s-worker-ai · k8s-worker-ai-2

    Az AI-készlet scan-workere (Celery · gevent) átveszi, és futtatja a Vision → Rule → Answer → Reward lépéseket. A négy szakasz láncba kötött Celery-feladat, nem csomópont.

  7. AI-készletk8s-worker-ai · k8s-worker-ai-2HTTPSLLM API

    A scan- és chat-feldolgozók az OpenAI és a Google API-jait hívják.

  8. scan-workerk8s-worker-ai · k8s-worker-ai-2XADD scan:eventsStreamsk8s-redis-streams

    Az előrehaladási események a négy Streams-shard egyikébe íródnak.

  9. Streamsk8s-redis-streamsXREADGROUPEvent Routerk8s-event-router

    Az Event Router fogyasztói csoportként olvassa őket, és feldolgozás után XACK-et küld; a pending és a reclaim legalább egyszeri kézbesítést biztosít.

  10. Event Routerk8s-event-routerSETEX stateState KVk8s-redis-streams

    A legutóbbi állapotot és egy duplikált feldolgozást jelző markert ugyanannak a Redis-csomópontnak a State KV-jébe írja.

  11. Event Routerk8s-event-routerPUBLISHPub/Subk8s-redis-pubsub

    Valós időben kézbesítve a job csatornáján, shard Pub/Sub-ban.

  12. Pub/Subk8s-redis-pubsubSUBSCRIBESSE Gatewayk8s-sse-gateway

    Az SSE Gateway folyamatonként egyetlen közös listenerrel iratkozik fel, és minden csatlakozott böngészőnek továbbítja őket.

  13. SSE Gatewayk8s-sse-gatewaySSE-streamBöngésző

    Ugyanazon az ALB- és ingress-útvonalon nyitott kapcsolat. A kézbesítés legalább egyszeri (at-least-once); a duplikátumok kezelése idempotens.

  14. State KVk8s-redis-streamsHelyreállítás újracsatlakozáskorSSE Gatewayk8s-sse-gateway

    Last-Event-ID-vel történő újracsatlakozáskor a State KV és a megőrzött Streams pótolja a kimaradt eseményeket.

Chat · tokenek és tárolás

A Chat-tokenek ugyanazt az eseményutat járják be, mint a Scané; az ellenőrzőpontokat és az üzeneteket két különböző munkaterhelés tárolja.

  1. BöngészőHTTPS 443AWS ALB

    A TLS az ALB-nél ér véget.

  2. AWS ALBHTTP · NodePortIstio ingress Envoyk8s-ingress-gateway

    Az EC2-példány célpontjának NodePortján keresztül jut az Istio ingress Envoyhoz.

  3. Istio ingress Envoyk8s-ingress-gatewayVirtualServiceChat APIk8s-api-chat

    A Chat API-hoz irányítva.

  4. Chat APIk8s-api-chatTaskiq-feladatRabbitMQk8s-rabbitmq

    A Chat-feladat a RabbitMQ-ra kerül.

  5. RabbitMQk8s-rabbitmqconsumechat-workerk8s-worker-ai · k8s-worker-ai-2

    A chat-worker (Taskiq · asyncio) LangGraph-fal osztályozza a szándékot, majd szükség esetén futtatja a vision lépést, a kiválasztott eszközöket, az aggregátort és szükség esetén egy összegzést, végül válaszol. Minden kérés csak a szükséges ágakat futtatja.

  6. AI-készletk8s-worker-ai · k8s-worker-ai-2HTTPSLLM API

    A scan- és chat-feldolgozók az OpenAI és a Google API-jait hívják.

  7. chat-workerk8s-worker-ai · k8s-worker-ai-2XADD chat:eventsStreamsk8s-redis-streams

    A tokenek és a szakaszesemények négy Streams-shardba íródnak; innen a kézbesítési út ugyanaz, mint a Scané.

  8. Streamsk8s-redis-streamsXREADGROUPEvent Routerk8s-event-router

    Az Event Router fogyasztói csoportként olvassa őket, és feldolgozás után XACK-et küld; a pending és a reclaim legalább egyszeri kézbesítést biztosít.

  9. Event Routerk8s-event-routerPUBLISHPub/Subk8s-redis-pubsub

    Valós időben kézbesítve a job csatornáján, shard Pub/Sub-ban.

  10. Pub/Subk8s-redis-pubsubSUBSCRIBESSE Gatewayk8s-sse-gateway

    Az SSE Gateway folyamatonként egyetlen közös listenerrel iratkozik fel, és minden csatlakozott böngészőnek továbbítja őket.

  11. SSE Gatewayk8s-sse-gatewaySSE-streamBöngésző

    Ugyanazon az ALB- és ingress-útvonalon nyitott kapcsolat. A kézbesítés legalább egyszeri (at-least-once); a duplikátumok kezelése idempotens.

  12. chat-workerk8s-worker-ai · k8s-worker-ai-2checkpointCachek8s-redis-cache

    A LangGraph-ellenőrzőpont a Redis Cache-ben marad.

  13. Cachek8s-redis-cacheellenőrzőpont olvasásacheckpoint-syncerk8s-worker-ai · k8s-worker-ai-2

    A checkpoint-syncer beolvassa az ellenőrzőpontot a Redisből.

  14. checkpoint-syncerk8s-worker-ai · k8s-worker-ai-2szinkronizálás PostgreSQL-bePostgreSQLk8s-postgresql

    Az AsyncPostgresSaver aszinkron módon tárolja a PostgreSQL-ben.

  15. Streamsk8s-redis-streamschat-persistence grouppersistence consumerk8s-api-chat

    A Chat-csomóponton futó persistence consumer fogyasztói csoportként olvassa a done eseményeket.

  16. persistence consumerk8s-api-chatüzenetek mentésePostgreSQLk8s-postgresql

    A Chat-üzenetek a PostgreSQL-be mentődnek. Ez a checkpoint-syncertől eltérő munkaterhelés.

Belépés · hitelesítés

A klaszter belépési pontjától egy domain-API-ig tartó szinkron útvonal. Csak a szabályzattal védett útvonalak ellenőrzik előbb a hitelesítést; a csomópontok közötti podforgalom Calico VXLAN-on fut.

  1. BöngészőDNS-lekérdezésRoute 53

    Csak a név oldódik fel a Route 53-rekordokból. A kérések nem haladnak át a DNS-en.

  2. BöngészőHTTPS 443AWS ALB

    A TLS az ALB-nél ér véget.

  3. AWS ALBHTTP · NodePortIstio ingress Envoyk8s-ingress-gateway

    Az EC2-példány célpontjának NodePortján keresztül jut az Istio ingress Envoyhoz.

  4. Istio ingress Envoyk8s-ingress-gatewayext-authz · gRPC 50051ext-authzk8s-api-auth

    Csak a CUSTOM szabályzat alá eső útvonalak kérdezik meg előbb a Go ext-authz-t (2 s időkorlát, failOpen false). Az olyan útvonalak, mint a login, a health és a docs, kivételek.

  5. ext-authzk8s-api-authtiltólista-lekérdezésblacklistk8s-redis-auth

    A tokent a Redis-tiltólistán ellenőrzi.

  6. Istio ingress Envoyk8s-ingress-gatewayVirtualServiceChat APIk8s-api-chat

    A Chat API-hoz irányítva.

  7. Chat APIk8s-api-chatgRPCimages APIk8s-api-image

    A README-ben megnevezett chat → images szinkron hívás.

  8. auth APIk8s-api-authgRPCusers APIk8s-api-users

    A README-ben megnevezett auth → users szinkron hívás.

Tárolókészlet · aszinkron írások

A hitelesítési tiltólistát és a karaktertulajdonlást a tárolókészlet feldolgozói tárolják, amelyek a RabbitMQ-ból kapják a munkát.

  1. blacklistk8s-redis-authoutbox:blacklistauth-relayk8s-worker-storage · k8s-worker-storage-2

    Az auth-relay (a README-ben auth-Bus) olvassa a Redis outboxot.

  2. auth-relayk8s-worker-storage · k8s-worker-storage-2blacklist.eventsRabbitMQk8s-rabbitmq

    Újrapublikál a RabbitMQ-ra, újrapróbálkozásokkal és DLQ-val.

  3. RabbitMQk8s-rabbitmqblacklist.eventsauth-workerk8s-worker-storage · k8s-worker-storage-2

    Az auth-worker fogadja a tiltólista-eseményeket.

  4. auth-workerk8s-worker-storage · k8s-worker-storage-2tiltólista tárolásablacklistk8s-redis-auth

    A Redis-tiltólistán tárolódnak.

  5. RabbitMQk8s-rabbitmqCelery batchusers-workerk8s-worker-storage · k8s-worker-storage-2

    A users-worker kötegekben kapja meg a karaktertulajdonlási munkákat.

  6. users-workerk8s-worker-storage · k8s-worker-storage-2UPSERTPostgreSQLk8s-postgresql

    A PostgreSQL-ben érvényesíti őket.

Konfigurálás · skálázás · megfigyelés

A Platform Layer nem olyan lépés, amelyen a kérések áthaladnak; telepíti, konfigurálja, skálázza és megfigyeli a többi réteget. A csomópontok Terraformmal létrehozott EC2-példányok, amelyekre az Ansible telepíti a kubeadm-et és a Calicót; a CI csak validálja a Terraformot, automatikusan soha nem alkalmazza.

  1. GitHub Actions · Docker Hubkonténerkép · manifest-revízióArgo CD image updaterk8s-master

    Az Argo CD App-of-Apps és Sync Waves segítségével igazítja a klaszter konfigurációját. A vezérlősíkon való elhelyezést csak az image updater esetében igazolták.

  2. ALB Controller · ExternalDNSk8s-masterIngress → ALB · DNS-rekordokAWS által felügyelt

    Az ALB Controller és az ExternalDNS konfigurálja az AWS-oldali erőforrásokat. A kérések nem ezen az útvonalon haladnak.

  3. Istiodk8s-masterxDS-konfigurációIstio ingress Envoyk8s-ingress-gateway

    Az Istiod xDS-en keresztül küldi a Gateway-, VirtualService- és EnvoyFilter-konfigurációt az ingress Envoynak és minden API Envoy sidecarjának.

  4. KEDAk8s-monitoringpodszámAI-készletk8s-worker-ai · k8s-worker-ai-2

    A KEDA a worker podok számát állítja. A csomópontok száma nem változik.

  5. KEDAk8s-monitoringpodszámtárolókészletk8s-worker-storage · k8s-worker-storage-2

    A tárolókészlet worker podjai ugyanígy skálázódnak.

  6. Fluent BitnaplókElasticsearchk8s-logging

    A Fluent Bit minden csomóponton DaemonSetként fut, és az Elasticsearchnek küldi a naplókat.

  7. AI-készletk8s-worker-ai · k8s-worker-ai-2LLM-futtatások nyomkövetéseLangSmith

    Az LLM-hívások nyomkövetési adatai a LangSmithbe, egy külső SaaS-be kerülnek.

Minden kapcsolat azonos vastagsággal. Válasszon egy folyamatot, hogy csak annak útvonala emelődjön ki, számozott lépésekkel.

  • Folytonos · a kérések, munkák, események és írások áramlási iránya
  • Pontozott · DNS-lekérdezés; a kérések nem haladnak át rajta
  • Szaggatott · konfigurálás vagy skálázás; nem adatút
  • Hosszú pontvonalas · naplók és futtatáskövetés
  • Vastag fekete vonal · a kiválasztott folyamat; a számok a sorrendet jelzik
  • Doboz · fizikai csomópont, fejlécében a hostnévvel
  • Belső chip · a csomóponton futó munkaterhelés
  • Szaggatott keret · kétcsomópontos ütemezési készlet
  • Szaggatott doboz · a klaszteren kívül, nem számít csomópontnak
  • Narancssárga körvonal · ahol egy modell dönt
  • Control plane1 csomópont
  • Domain API8 csomópont
  • AI-készlet2 csomópont
  • tárolókészlet2 csomópont
  • Data5 csomópont
  • Platform6 csomópont

A README öt rétege (a sávok) és a fizikai csoportok (az egyes csomópontok fejlécének árnyalata) ugyanazt a 24 csomópontot eltérően csoportosítja. A State KV a Streams-csomóponton osztozik, ezért nincs külön számolva; a Route 53, az ALB és a klaszteren kívüli szolgáltatások nem csomópontok. A készlet ütemezési tartomány, nem állítás arról, hogy minden pod mindkét csomóponton fut.

24 csomópontos elrendezés · a 2026. január 21-i irányítópult csomópontlistája alapján

24csomópont

24 = 1 control plane + 8 API + 4 worker + 5 data + 6 platform

  1. 1Control plane

    role: control-plane

    kube-apiserver · scheduler · controller-manager · etcd, valamint a platformkontrollerek.

    1. k8s-master

  2. 8Domain API

    domain: <szolgáltatás>

    Domainenként egy csomópont. A belső hívások gRPC-t használnak.

    1. k8s-api-auth
    2. k8s-api-users
    3. k8s-api-scan
    4. k8s-api-character
    5. k8s-api-location
    6. k8s-api-image
    7. k8s-api-chat
    8. k8s-api-info

  3. 4Execution worker

    Két ütemezési készlet, mindkettő két csomóponttal. A KEDA a podok számát változtatja; a csomópontok száma ugyanaz marad.

    tárolókészletdomain: worker-storage
    1. k8s-worker-storage
    2. k8s-worker-storage-2
    AI-készletdomain: worker-ai
    1. k8s-worker-ai
    2. k8s-worker-ai-2

  4. 5Data

    A Redis négy célspecifikus csomópontra van bontva. A PostgreSQL tárolója EBS CSI · gp3.

    1. k8s-postgresql
    2. k8s-redis-auth
    3. k8s-redis-streams
    4. k8s-redis-cache
    5. k8s-redis-pubsub

  5. 6Platform

    Az üzenetkezelés, a megfigyelhetőség, az ingress és a valós idejű kézbesítés saját csomópontot kapott.

    1. k8s-rabbitmq
    2. k8s-monitoring
    3. k8s-logging
    4. k8s-ingress-gateway
    5. k8s-sse-gateway
    6. k8s-event-router
Minden csomópont
  • Fluent Bit · DaemonSet
  • Calico

Konfigurált modellek · szolgáltatónként

A szolgáltatás megszűnt, így ezek a tárolóban konfigurált modellek, nem ma választható lehetőségek. Minden szerep külön szerepel; ez nem ellenőrzött futtatások listája.

  • OpenAI

    A Chat alapértelmezett szolgáltatója

    Chat

    • openai/gpt-5.2alapértelmezett

    Az alapértelmezett modell a gpt-5.2; a kérésben megnevezett modell lép a helyére.

    Scan

    • gpt-5.2alapértelmezett
    • gpt-5.2-pro
    • gpt-5.1
    • gpt-5
    • gpt-5-pro
    • gpt-5-mini

    A 13 modellből álló leképezésen kívüli modelleket elutasítja.

    Képleképezés

    • gpt-image-1.5

    Elkülönül a gpt-5.2-től, a Responses orkesztrációs modelltől. A képgenerálás alapértelmezésben ki van kapcsolva.

    Kiértékelés

    • gpt-4o-minialapértelmezett

    A beszélgetés-kiértékelés LLM-alapú pontozója, elkülönül a Chat modelljétől.

  • Google

    Ha a Chat a Google-t választja

    Chat

    • google/gemini-3-pro-preview
    • google/gemini-3-flash-preview

    Google választása esetén a gemini-3-flash-preview az alapértelmezett.

    Scan

    • gemini-3-pro-preview
    • gemini-3-flash-preview
    • gemini-2.5-pro
    • gemini-2.5-flash
    • gemini-2.5-flash-lite
    • gemini-2.0-flash
    • gemini-2.0-flash-lite

    Képleképezés

    • gemini-3-pro-image-preview

Forrásbackend main d8840c7Nyilvános commit: 2026. szeptember 29. · ellenőrizve: 2026. október 8.