अध्याय · अपना data जोड़ें
एक call एक source पंजीकृत करती है, एक typed schema अनुमानित करती है, और उसका revision हर उस plan में pin करती है जो उसे स्पर्श करता है। Files और SQLite in-process चलते हैं — कोई key नहीं, कुछ बाहर नहीं जाता। Live databases engine के माध्यम से जुड़ते हैं — सीधे, प्रत्येक database के अपने wire protocol पर: credentials encrypted, कोई data copied नहीं।
›const sales = await sqai.connect("./data/sales.csv", { name: "sales" })
→ row_count 12 · schema_revision e4938027… · status ready
टाइप्ड · हैश-पिन्ड · केवल-पठन
IItype cases
हर drawer एक ही contract पर खुलता है: यह कैसे जुड़ता है, क्या चाहिए, क्या बाहर जाता है। एक खोलें।
In-processकोई key नहीं · कोई daemon नहीं · कोई network नहीं
"./data/sales.csv""./data/orders.tsv""./data/sales.json"[{ region: "east", revenue: 512 }, …]{ records: [ … ] }{ provider: "sqlite", path, table | query }"./data/sales.xlsx""./data/sales.parquet"Engine के माध्यम सेcredentials encrypted · कोई data copied नहीं
{ type: "postgres", host, port, database, user, password, table | query }{ type: "mysql", host, port, database, user, password, table | query }{ type: "oracle", host, port, database, user, password, table | query }{ type: "mssql", host, port, database, user, password, table | query }{ type: "snowflake", connection_string, query }{ type: "bigquery", connection_string, query }{ type: "clickhouse", connection_string, query }{ type: "redshift", connection_string, query }{ type: "s3", … }{ type: "gcs", … }{ type: "azure_blob", … }{ type: "redis", … }{ type: "neo4j", … }{ type: "elasticsearch", … }{ type: "rest", … }{ type: "github", … }{ type: "gitlab", … }{ type: "bitbucket", … }मोड परिवेश से स्वतः निर्धारित होता है
SQAI_ENGINE_URLself_hosted
आपका इंजन, आपका नेटवर्क।
SQAI_API_KEYapi
होस्टेड इंजन।
कोई भी सेट नहींlocal
केवल इन-प्रोसेस।
फ़ाइलें और SQLite हर मोड में काम करते हैं। लाइव डेटाबेस के लिए api या self_hosted आवश्यक है। इंजन एक बार कनेक्शन स्थापित करता है, फिर सक्रिय रहता है — एक स्थायी डेमन, प्रति-क्वेरी कोल्ड स्टार्ट नहीं।
डेटाबेस के स्वयं के वायर प्रोटोकॉल पर प्रत्यक्ष कनेक्टिविटी
IIIवायर
इंजन सीधे जुड़ता है, प्रत्येक डेटाबेस का अपना वायर प्रोटोकॉल बोलते हुए। क्वेरी वहीं चलती हैं, आपके संगठन तक सीमित — आपका डेटाबेस कभी कॉपी नहीं होता।
इंजन आपके डेटा को वहीं क्वेरी करता है जहाँ वह रहता है, आपके संगठन तक सीमित — और कभी उससे आगे नहीं जाता जो आपने कॉन्फ़िगर किया है।
विश्राम पर एन्क्रिप्टेड, org-स्कोप्ड, केवल आपके संगठन की क्वेरी सेवा के लिए उपयोग। एक कनेक्टर अपना कॉन्फ़िग कभी नहीं लौटाता — केवल नाम, प्रकार, स्थिति और अंतिम परीक्षण परिणाम।
इंजन आपका डेटाबेस कभी कॉपी नहीं करता — पंक्तियाँ वहीं पढ़ी जाती हैं जहाँ वे रहती हैं।
›SELECT 1ok · connector: live
हर परीक्षण एक वास्तविक कनेक्शन खोलता है — SQL के लिए SELECT 1, ऑब्जेक्ट स्टोरेज के लिए HEAD, REST के लिए सैंपल फ़ेच। कनेक्टर तभी लाइव होता है जब वास्तविक कनेक्शन सफल हो; कॉन्फ़िग संपादित करने पर वह अपरीक्षित स्थिति में लौट जाता है।
प्रमुख वायर · Oracle
इंजन python-oracledb को Thin मोड में बंडल करता है और सीधे जुड़ता है — कोई Instant Client नहीं, कोई अतिरिक्त रनटाइम प्रक्रिया नहीं, कोई अतिरिक्त Python पैकेज नहीं। इंजन वायर को पूरी तरह नियंत्रित करता है: ड्राइवर, बाउंडेड कनेक्शन पूल, क्रेडेंशियल सत्यापन, स्कीमा ब्राउज़, और एक Arrow-संगत बैच फ़ेच पाथ — कोई छिपा हुआ अनपूल्ड फ़ॉलबैक कनेक्शन नहीं।
तालिकाएँ PostgreSQL वायर प्रोटोकॉल पर यथास्थान पढ़ी जाती हैं — क्लस्टर कभी कॉपी नहीं होता। परीक्षण सफलता संदेश भी PostgreSQL का नाम लेता है।
ऑब्जेक्ट स्टोरेज और अपलोड एक ही पार्सर साझा करते हैं — S3 में एक Parquet ऑब्जेक्ट और एक अपलोड की गई Parquet फ़ाइल इंजन में एक समान पहुँचती हैं।
समान अनुरोध → समान पंक्तियाँ, समान क्रम · हर एक्सेस ऑडिट योग्य · एग्रेस एक फेल-क्लोज्ड प्रति-डिप्लॉयमेंट अनुमति सूची है
IVएकरूपता
हर source एक ही typed SqaiSource लौटाता है — समान fields, समान pins, समान गारंटी। warehouse को file की जगह रखें और downstream में कुछ नहीं बदलता।
"./data/sales.csv"{ type: "snowflake", connection_string, query }SqaiSource
एक ही आकार · हर sourceएक प्रमाणपत्र, चाहे source कोई भी हो। Downstream कोड को कभी पता नहीं चलता कि rows कहाँ हैं।
नाम फिर से बाँधने पर error आती है source_already_registered
VThe pin
connect() हर plan और computation में एक schema revision pin करता है। बदले हुए डेटा पर stored plan replay करने पर बदलाव सामने आता है — चुपचाप गलत संख्याएँ नहीं।
schema_revisionschema_revision_mismatchsource_already_registeredprovenance.bindings[0]
source_name"sales"fields["revenue"]schema_revisione4938027…c9b8cfberow_count12input_hash2ea5ede7…478e3212हर bound field अपनी वंशावली साथ रखता है।
VIप्रश्न
connect() से code में source पंजीकृत करें। Model को connection string कभी नहीं दिखती — उसे typed sources पर तीन read-only tools मिलते हैं, और policy तय करती है कि वह कौन से sources और fields छू सकता है।
नहीं। In-process sources आपकी machine नहीं छोड़ते। Engine sources में credentials encrypted रहते हैं; rows माँगने पर पढ़ी जाती हैं और कभी copy नहीं होतीं।
इनमें से कुछ नहीं। Connectivity सीधे डेटाबेस के अपने wire protocol से होती है — engine आपके डेटा को उसी जगह query करता है, आपके organization के scope में, और आपका डेटाबेस कभी copy नहीं करता।
Files, in-memory rows, या SQLite के लिए नहीं — ये बिना किसी account के in-process चलते हैं। Live databases और warehouses के लिए hosted engine हेतु SQAI_API_KEY, या अपने engine के लिए SQAI_ENGINE_URL चाहिए।
नहीं। Credentials आपके code में connect() के समय दिए जाते हैं और engine पर encrypted होते हैं। Model के tool input में typed intent होता है — कोई connection details नहीं, कोई policy fields नहीं।
हाँ। Engine में एक bundled Thin-mode driver शामिल है, इसलिए कोई Oracle client install नहीं करना पड़ता।
connect के समय pin की गई schema_revision मेल खाना बंद कर देती है, और replay चुपचाप गलत संख्याओं की बजाय schema_revision_mismatch दिखाता है। किसी पंजीकृत नाम को फिर से bind करने पर source_already_registered आती है।
Node ≥ 20 · Python ≥ 3.10 · फ़ाइलें और SQLite के लिए कोई key आवश्यक नहीं