Aurabase का Rust कोर: एक एकीकृत बैकएंड-ए-ए-सर्विस

अधिकांश ओपन सोर्स पोस्टग्रेज़ BaaS अपनी सेवाओं को कई भाषाओं में पैकेज करते हैं। यह एक मूल्य निर्णय नहीं है - यह एक वास्तुशिल्प तथ्य है जिसके ठोस परिणाम हैं: सिंक्रनाइज़ेशन में रखने के लिए कई संकलन श्रृंखलाएं, त्रुटि सम्मेलन और ऑथ तर्क जैसे कि खेल में भाषाएं हैं।

ऑराबेस में, उत्पाद परत जिसे हम लिखते हैं और स्वयं बनाए रखते हैं - गेटवे, ऑथ, डेटाबेस, वास्तविक समय, भंडारण, सूचनाएं, एआई, प्रावधान, खाता प्रबंधन - एक एकल कार्गो कार्यक्षेत्र, एक एकल भाषा, एक एकल निर्माण श्रृंखला है। यह विकल्प है कि यह फ़ाइल दस्तावेज़ बनाती है.

रूट Cargo.toml 18 सदस्यों के साथ रिज़ॉल्वर v2 में एक कार्गो वर्कस्पेस घोषित करता है: 11 व्यावसायिक सेवाएँ, aura-cliCLI, 5 साझा लाइब्रेरी और aurabase-rsSDK। यहां वास्तविक सूची है, जैसा कि भंडार में दिखाई देता है।

[workspace]
resolver = "2"

members = [
    # सेवाएँ (11)
    "services/aura-gateway", "services/aura-auth", "services/aura-db",
    "services/aura-provisioner", "services/aura-realtime", "services/aura-storage",
    "services/aura-functions", "services/aura-notifications", "services/aura-ai",
    "services/aura-migrator", "services/aura-control",
    # औजार
    "aura-cli",
    # लिब्ज़ (5)
    "libs/aura-core", "libs/aura-crypto", "libs/aura-db-adapters",
    "libs/aura-migrations", "libs/aura-telemetry",
    "aurabase-rs",
]

साझा निर्भरताएँ [workspace.dependencies]में रहती हैं: Axum 0.8 (WebSockets, मल्टीपार्ट, मैक्रोज़ के साथ), टोकियो, टॉवर/टॉवर-HTTP, SQLx 0.8 (माध्यमिक NoSQL इंजन के लिए mongodb के माध्यम से Postgres + MongoDB), async-nats 0.47, sqlparser 0.53 (NL2SQL का SQL सत्यापन), oauth2 5, jsonwebtoken 10, और दो प्रदर्शन libs लगभग हर सेवा में पाए जाते हैं: mimalloc एक वैश्विक आवंटनकर्ता के रूप में और moka/dashmap इन-मेमोरी कैश के लिए।

रिलीज़ प्रोफ़ाइल एक कल्पित विकल्प का दस्तावेजीकरण करती है: "abort"के बजाय panic = "unwind"। फ़ाइल टिप्पणी स्व-व्याख्यात्मक है - पूरी प्रक्रिया को नीचे लाने और प्रतिस्पर्धी अनुरोधों को काटने के बजाय एक्सम/टोकियो हैंडलर में घबराहट को रनटाइम (प्रभावित अनुरोध 500 लौटाता है) द्वारा अलग किया जाता है। इसी नोट के अनुसार,abort (आरपीएस का लगभग 1 से 2%) का प्रदर्शन लाभ इन्सुलेशन के नुकसान के लायक नहीं है। यह एक विश्वसनीयता-बनाम-स्पीड ट्रेड-ऑफ है जिसे कोड में दर्ज किया गया है, न कि कोई मार्केटिंग दावा।

एक cargo build --workspace पूरी चीज़ को संकलित करता है। एक एकल cargo test --workspace संपूर्ण परीक्षण सूट चलाता है। एक एकल cargo clippy --workspace --all-targets -- -D warnings पूरे उत्पाद को समान नियमों के साथ जोड़ता है। इस संरचना का विवरण - निर्भरता की विरासत, libs और सेवाओं के बीच आंतरिक ग्राफ, इसे विकसित करते समय हमारे सामने आने वाले नुकसान - एक समर्पित लेख का विषय हैं: कार्गो वर्कस्पेस आर्किटेक्चर, मल्टी-सर्विस रस्ट बैकएंड की संरचना कैसे करें।

सेवा द्वारा जंग रेखाएँ (सेवाएँ खोजें -नाम '*.rs' | xargs wc -l, 23 अगस्त, 2026):

आभा-नियंत्रण

36 024

आभा-डीबी

30 255

आभा-प्रामाणिक

28 431

आभा-प्रदाता

28 271

आभा-सूचनाएँ

18 498

होगा

18 305

आभा-द्वार

16 938

आभा-वास्तविक समय

16 799

आभा-भंडार

13 747

आभा-कार्य

11 619

आभा-प्रवासी

538

साझा लिब्ज़ (ऑरा-डीबी-एडेप्टर: 24,725 लाइनें, ऑरा-कोर: 7,259, ऑरा-माइग्रेशन: 3,641, ऑरा-क्रिप्टो: 2,718, ऑरा-टेलीमेट्री: 201), सीएलआई (ऑरा-सीएलआई: 9,845) और रस्ट एसडीके (ऑराबेस-आरएस: 6,363) को छोड़कर। ऑरा-माइग्रेटर, एक एकल-उपयोग माइग्रेशन कार्य और लंबे समय तक चलने वाला HTTP सर्वर नहीं, जानबूझकर कार्यक्षेत्र में सबसे छोटी सेवा बनी हुई है।

प्रत्येक सेवा अपने स्वयं के कॉन्फ़िगरेशन और पोर्ट के साथ एक स्वतंत्र एक्सम/टोकियो बाइनरी है। ग्यारह में से दस /health और /metrics को उजागर करते हैं और mimalloc को वैश्विक आवंटनकर्ता घोषित करते हैं - एकमात्र अपवाद, aura-migrator, लगातार चलने वाले सर्वर के बजाय एकल-उद्देश्यीय कार्य है।

aura CLI (≈ 9,800 लाइनें) SDKs के समान API से बात करती है - इसका कोई विशेषाधिकार प्राप्त पथ नहीं है। प्रत्येक सेवा का पूरा संदर्भ आर्किटेक्चर दस्तावेज़ और CLI संदर्भमें रहता है।

पॉलीग्लॉट स्टैक में, एक सुरक्षा नियम - त्रुटि प्रारूप, एसएसआरएफ सुरक्षा, दर सीमित करना - प्रत्येक भाषा में फिर से लागू किया जाना चाहिए, और लगभग हमेशा महीनों में बदलता रहता है। ऑराबेस इसे वर्कस्पेस लिब में एक बार कोड करता है, जिसका उपभोग सभी संबंधित सेवाओं द्वारा किया जाता है।

प्रत्यक्ष परिणाम: aura-core में एक सुरक्षा पैच - उदाहरण के लिए, SSRF सुरक्षा - अगले cargo buildमें प्रत्येक उपभोक्ता सेवा तक प्रसारित होता है, न कि पांच भाषाओं में पांच अलग-अलग पैच के माध्यम से।

aura-gateway दो सतहों को अलग करता है जिनके न तो समान क्लाइंट हैं और न ही समान ऑथ मॉडल। डेटा प्लेन (पोर्ट 8080, वेरिएबल GATEWAY_PORT) SDK/ऐप ट्रैफ़िक प्राप्त करता है, जो API कुंजी (apikey, X-API-Key या ?apikey=) द्वारा प्रमाणित होता है। प्रबंधन विमान (पोर्ट 8090, MANAGEMENT_PORT) स्टूडियो/एडमिन ट्रैफ़िक प्राप्त करता है, जो JWT कंसोल (Authorization: Bearer) द्वारा प्रमाणित होता है।

// डेटा प्लेन - एपीआई कुंजी
.route("/v1/auth/{*path}", any(auth_proxy))
.route("/v1/db/{*path}", any(db_proxy))
.route("/v1/realtime/ws", get(realtime_ws_proxy))
.route("/v1/realtime/sse", get(realtime_sse_proxy))
.route("/v1/storage/{*path}", any(storage_proxy))
.route("/v1/notifications/{*path}", any(notifications_proxy))
.route("/v1/ai/{*path}", any(ai_dispatcher))
.route("/v1/functions/{*path}", any(functions_proxy))

// प्रबंधन योजना - जेडब्ल्यूटी कंसोल
.route("/v1/control/{*path}", any(control_proxy))

प्रत्येक विमान में मिडलवेयर का अपना ढेर होता है - क्वेरी पहचान, एक्सेस लॉग, दर सीमा, प्रमाणीकरण (विमान-विशिष्ट), सर्किट ब्रेकर, फिर प्रॉक्सी - अलग-अलग मॉड्यूल (middleware/rate_limit.rs, middleware/circuit_breaker.rs, middleware/auth_data_plane.rs, middleware/auth_management_plane.rs) में कार्यान्वित किया जाता है, न कि दो सतहों के बीच गलती से साझा की गई एक श्रृंखला के बजाय, जिन्हें एक-दूसरे पर समान रूप से भरोसा नहीं करना चाहिए। रास्ता।

मिडलवेयर का सटीक क्रम, प्रति लक्ष्य सीमित दर और NATS/HTTP प्रॉक्सी एक समर्पित लेख का विषय हैं: डुअल-प्लेन गेटवे, रस्ट में डेटा-प्लेन/मैनेजमेंट-प्लेन एपीआई गेटवे डिज़ाइन करें।

SDK द्वारा उपभोग की जाने वाली स्व-निर्मित REST API एक इन-हाउस रस्ट मॉड्यूल नहीं है: यह वास्तविक अपस्ट्रीम बाइनरी PostgREST (postgrest/postgrest:v12.2.8) है, जो प्रति समर्पित प्रोजेक्ट (deploy/cnpg/tenant-postgrest.yaml) में 2 प्रतिकृतियों में तैनात है, जो किरायेदार के CNPG इंस्टेंस के साथ सह-स्थित है। aura-provisioner यह परिनियोजन बनाता है, और aura-db प्रत्येक स्कीमा पुनः लोड के बाद इसके समापन बिंदु OPTIONS की जांच करता है ताकि यह पुष्टि हो सके कि PostgREST ने DDL परिवर्तन को ध्यान में रखा है।

यह एक अनुमानित वास्तुशिल्प विकल्प है, कोई शॉर्टकट नहीं: PostgREST एक परिपक्व, व्यापक रूप से अपनाया गया प्रोजेक्ट है, जिसके व्यवहार को रस्ट में थोड़ा-थोड़ा करके फिर से लिखने से कुछ नहीं मिलेगा। ऑराबेस का रस्ट कार्य चारों ओर केंद्रित है - मल्टी-टेनेंट रूटिंग, प्रोविजनिंग, नेटवर्कपॉलिसी द्वारा नेटवर्क अलगाव, गेटवे के साथ साझा प्रमाणीकरण, ऑर्केस्ट्रेटेड स्कीमा रीलोड - क्वेरी इंजन के अंदर ही नहीं। यह अनुकूलता वास्तव में क्या कवर करती है, और यह कहां रुकती है, यह एक अलग लेख का विषय है: PostgREST, वास्तविक अनुकूलता औरविकल्प।

ग्राफक्यूएल पक्ष पर समान तर्क: पोस्टग्रेज एक्सटेंशन pg_graphql (पूर्व संकलित .deb पैकेज, v1.6.1) समर्पित सीएनपीजी छवि में स्थापित किया गया है और POST /v1/control/projects/{project_id}/graphql/enable एंडपॉइंट के माध्यम से प्रति प्रोजेक्ट मांग पर सक्रिय किया गया है - या तो फिर से लिखा गया ग्राफक्यूएल इंजन नहीं है। हसुरा और पोस्टग्राफाइल के साथ विवरण और ईमानदार तुलना: pg_graphqlके साथ पोस्टग्रेज पर नेटिव ग्राफक्यूएल एपीआई।

बहु-किरायेदार अलगाव किसी एप्लिकेशन ORM द्वारा जोड़े गए WHERE tenant_id = ? फ़िल्टर पर निर्भर नहीं करता है: प्रत्येक अनुरोध aura_authenticatorभूमिका से गुजरता है, जो अनुरोध को निष्पादित करने से पहले SET LOCAL ROLE tenant_<uuid> लेनदेन-स्कोप को निष्पादित करता है - बिल्कुल वही मॉडल जो PostgREST स्वयं अपेक्षा करता है। पंक्ति-स्तरीय सुरक्षा बाकी काम इंजन स्तर पर करती है, व्यवसाय कोड स्तर पर नहीं।

सभी प्रोजेक्ट समान पोस्टग्रेज़ टोपोलॉजी साझा नहीं करते हैं। aura-provisioner कोड कम से कम दो वास्तविक वेरिएंट के साथ ProjectInstanceKind प्रकार को उजागर करता है: FullyDedicated (CNPG उदाहरण पूरी तरह से परियोजना के लिए समर्पित) और SharedClusterDedicated (एक साझा CNPG क्लस्टर पर RLS द्वारा अलग किया गया स्कीमा)। सदस्यता प्राप्त योजना टोपोलॉजी निर्धारित करती है - यह "सभी के लिए समर्पित आधार" का एक समान वादा नहीं है।

ग्यारह व्यावसायिक सेवाओं में से दस async-nats को अपने Cargo.toml में प्रत्यक्ष निर्भरता के रूप में घोषित करती हैं - केवल aura-migrator इसके बिना काम करती है। यह क्रेट नाम क्या नहीं कहता है: ये सेवाएँ लगभग हर जगह NATS केकोर पब/सब एपीआई (Client::publish / publish_with_headers, बिना दृढ़ता या रीप्ले के अधिकतम एक बार डिलीवरी) का उपयोग करती हैं, न कि जेटस्ट्रीमका। यह उन तीन उपयोगों के लिए कोड में सत्यापित मामला है जो सबसे अधिक मायने रखते हैं: PostgreSQL CDC का aura-realtimeमें वितरण, aura-functions में एज फ़ंक्शंस नौकरियों की अधिसूचना (DLQ स्वयं Postgres में रहता है, NATS में नहीं), और aura-provisioner और बाकी बेड़े के बीच घटनाओं का प्रावधान।

जेटस्ट्रीम - NATS की दृढ़ता और नामित स्ट्रीम मोड - मोनोरेपो में केवल एक सत्यापित स्थान पर दिखाई देता है: aura-realtime (बकेट aura_presence, मेमोरी स्टोर, 60-सेकंड max_age) में क्रॉस-इंस्टेंस उपस्थिति KV स्टोर, जो सिंक्रनाइज़ करता है कि ws-front के कई उदाहरणों में कौन किस चैनल से जुड़ा है - एक क्रॉस-इंस्टेंस साझा स्थिति, फिर से चलाने के लिए घटनाओं की एक धारा नहीं। कार्यक्षेत्र में कहीं और कोई स्थायी जेटस्ट्रीम स्ट्रीम नहीं पाई गई। सीडीसी पाइपलाइन का विवरण - wal2json, लीज कुबेरनेट्स द्वारा एक अद्वितीय cdc-worker का चुनाव, ws-frontप्रतिकृतियों के लिए कोर NATS फैन-आउट, ग्राहक द्वारा RLS पुन: सत्यापन - एक समर्पित लेख का विषय हैं: ने PostgreSQL CDC को NATSके साथ प्रसारित किया। रीयलटाइम दस्तावेज़ SDK पक्ष पर उपयोग को कवर करता है।

यह इस फ़ाइल की सबसे महत्वपूर्ण बारीकियां है, और ऑराबेस उत्पाद कोड में शुद्ध रस्ट से एकमात्र वास्तविक विचलन है। प्रत्येक फ़ंक्शन में एक runtime फ़ील्ड होता है जिसका मूल्य "wasm" या "deno"होता है। इनवोकेशन हैंडलर तदनुसार निष्पादन पथ चुनता है - वास्तविक स्निपेट, कोड में ही टिप्पणी की गई है:

// रनटाइम के अनुसार प्रेषण: WASM (wasmtime) या डेनो (V8 एज-रनटाइम के माध्यम से आइसोलेट्स)
let resp = if func.runtime == "wasm" {
    state.runtime.invoke(&wasm_bytes, &func.code_hash, req).await?
} else {
    // ऑरा-एज-रनटाइम के लिए प्रॉक्सी - V8 आइसोलेट्स (सुपबेस/एज-रनटाइम, एमआईटी)
    proxy_to_edge_runtime(&state.config.edge_runtime_url, …).await?
};

wasm मोड मूल है: aura-functions सीधे Wasmtime (संस्करण 43, सुविधाएँ async और cranelift) पर निर्भर करता है और मॉड्यूल को उसी रस्ट प्रक्रिया में निष्पादित करता है, जिसमें ईंधन की गिनती, युग द्वारा रुकावट और StoreLimitsके माध्यम से मेमोरी बाउंडिंग होती है। deno मोड - स्टूडियो संपादक में डिफ़ॉल्ट रूप से उपयोग किया जाता है, मौजूदा सुपरबेस कोड के साथ लगभग प्रत्यक्ष Deno.serve() संगतता के लिए - निष्पादन को aura-edge-runtimeमें सौंपता है, लगभग 550 लाइनों की एक अलग टाइपस्क्रिप्ट सेवा, स्पष्ट रूप से मॉडलिंग की जाती है - स्रोत फ़ाइल हेडर टिप्पणी स्वयं इसे उद्धृत करती है - सुपरबेस/एज-रनटाइम पर (एमआईटी लाइसेंस), जो प्रत्येक आह्वान को अपने स्वयं के वी8 आइसोलेट में अलग करता है।

दोनों परिनियोजन पथों के कैसे करें दस्तावेज़ के लिए, एज फ़ंक्शंसदेखें। सुपाबेस से डेनो माइग्रेशन प्लेबुक के लिए, एक सुपाबेस प्रोजेक्ट को ऑराबेस में माइग्रेट करेंदेखें, जिसने इस फ़ाइल से पहले ही इस अंतर को प्रलेखित कर दिया है।

यदि आप केवल एसडीके के माध्यम से एपीआई को कॉल करते हैं, तो यह आर्किटेक्चर अदृश्य है - यही लक्ष्य है। यह मुख्य रूप से तीन दर्शकों के लिए मायने रखता है: वे जो उत्पादन डेटा को इसमें स्थानांतरित करने से पहले एक बहु-किरायेदार बैकएंड की परिचालन विश्वसनीयता का मूल्यांकन करते हैं, वे जो रिपॉजिटरी (एमआईटी, एकल मोनोरेपो) में योगदान करने की योजना बनाते हैं, और जो यह समझना चाहते हैं कि ऑराबेस पक्ष पर एक सुरक्षा पैच धीरे-धीरे के बजाय तेजी से क्यों फैलता है।

सीधे तौर पर: एक एकल आईसी (cargo build --workspace, cargo test --workspace, cargo clippy --workspace --all-targets -- -D warnings) उत्पाद की सतह का 90% या अधिक भाग कवर करता है। aura-core पर एक कोड समीक्षा संभावित रूप से एक साथ दस सेवाओं को प्रभावित करती है - बेहतर के लिए (एक सुधार रास्ते में नहीं खोता है) और बदतर के लिए (एक खराब पृथक परिवर्तन उतनी ही तेजी से फैलता है)। यह एक समझौता है, कोई जादुई समाधान नहीं - और यही कारण है कि हम मार्केटिंग सारांश के बजाय वास्तविक वास्तुकला का दस्तावेजीकरण करते हैं।

यह स्तंभ पृष्ठ क्लस्टर के तकनीकी विश्लेषणों से लिंक करता है, जैसा कि वे प्रकाशित होते हैं। इस पृष्ठ के प्रकाशन के समय वास्तविक स्थिति - संबंधित लेख ऑनलाइन होते ही लिंक सक्रिय हो जाते हैं।

क्लस्टर ए - रूपरेखा और वास्तुकला

एक्सम बनाम एक्टिक्स-वेब: उत्पादन में रस्ट बैकएंड के लिए कौन सा ढांचा?प्रकाशित

कार्गो वर्कस्पेस आर्किटेक्चर: मल्टी-सर्विस रस्ट बैकएंड की संरचना कैसे करेंप्रकाशित

डुअल-प्लेन गेटवे: रस्ट में डेटा-प्लेन/मैनेजमेंट-प्लेन एपीआई गेटवे डिजाइन करनाप्रकाशित

क्लस्टर बी - पोस्टग्रेज पर स्व-निर्मित एपीआई

PostgREST: संगतता वास्तव में क्या कवर करती है, और कौन से विकल्प मौजूद हैंप्रकाशित

pg_graphql के साथ पोस्टग्रेज पर नेटिव ग्राफक्यूएल एपीआई: हसुरा और पोस्टग्राफाइल वही नहीं करते हैंप्रकाशित

आरएलएस और प्रति परियोजना समर्पित आधार: ऑराबेस से बहु-किरायेदार इन्सुलेशन का विकल्पप्रकाशित

क्लस्टर सी - वास्तविक समय और संदेश

NATS के साथ PostgreSQL CDC वितरित करें: वास्तविक समय आर्किटेक्चरप्रकाशित

क्लस्टर डी - एज फ़ंक्शंस वेबअसेंबली

क्लस्टर ई - प्रवासन और विकल्प

अपनी RLS नीतियों को दोबारा लिखे बिना एक सुपाबेस प्रोजेक्ट को ऑराबेस में माइग्रेट करेंप्रकाशित

सॉवरेन सेल्फ-होस्टिंग: ऑराबेस को रस्ट-नेटिव बाएस के विरुद्ध स्थापित करना जल्द ही आ रहा है