Python Client | Geode Database

<h2 id="geode-python-client-library" class="position-relative d-flex align-items-center group"> Geode Python Client Library <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="geode-python-client-library" aria-haspopup="dialog" aria-label="Share link: Geode Python Client Library"> Share link </button> </h2><div id="headingShareModal" class="heading-share-modal" role="dialog" aria-modal="true" aria-labelledby="headingShareTitle" hidden> <div class="hsm-dialog" role="document"> <div class="hsm-header"> <h2 id="headingShareTitle" class="h6 mb-0 fw-bold">Share this section</h2> <button type="button" class="hsm-close" aria-label="Close"> </button> </div> <div class="hsm-body"> <label for="headingShareInput" class="form-label small text-muted mb-1 text-uppercase fw-bold" style="font-size: 0.7rem; letter-spacing: 0.5px;">Permalink</label> <div class="input-group mb-4 hsm-url-group"> <input id="headingShareInput" type="text" class="form-control font-monospace" readonly aria-readonly="true" style="font-size: 0.85rem;" /> <button class="btn btn-primary hsm-copy" type="button" aria-label="Copy" title="Copy"> </button> </div> <div class="small fw-bold mb-2 text-muted text-uppercase" style="font-size: 0.7rem; letter-spacing: 0.5px;">Share via</div> <div class="hsm-share-grid"> <a id="share-twitter" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Twitter </a> <a id="share-linkedin" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> LinkedIn </a> <a id="share-facebook" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Facebook </a> </div> </div> </div> </div> <style> .heading-share-modal { position: fixed; inset: 0; display: flex; justify-content: center; align-items: center; background: rgba(0, 0, 0, 0.6); z-index: 1050; padding: 1rem; backdrop-filter: blur(4px); -webkit-backdrop-filter: blur(4px); } .heading-share-modal[hidden] { display: none !important; } .hsm-dialog { max-width: 420px; width: 100%; background: var(--bs-body-bg, #fff); color: var(--bs-body-color, #212529); border: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); border-radius: 1rem; box-shadow: 0 25px 50px -12px rgba(0, 0, 0, 0.25); overflow: hidden; animation: hsm-fade-in 0.2s ease-out; } @keyframes hsm-fade-in { from { opacity: 0; transform: scale(0.95); } to { opacity: 1; transform: scale(1); } } [data-bs-theme="dark"] .hsm-dialog { background: #1e293b; border-color: rgba(255,255,255,0.1); color: #f8f9fa; } .hsm-header { display: flex; justify-content: space-between; align-items: center; padding: 1rem 1.5rem; border-bottom: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); background: rgba(0,0,0,0.02); } [data-bs-theme="dark"] .hsm-header { background: rgba(255,255,255,0.02); border-color: rgba(255,255,255,0.1); } .hsm-close { background: transparent; border: none; color: inherit; opacity: 0.5; padding: 0.25rem 0.5rem; border-radius: 0.25rem; font-size: 1.2rem; line-height: 1; transition: opacity 0.2s; } .hsm-close:hover { opacity: 1; } .hsm-body { padding: 1.5rem; } .hsm-url-group { display: flex !important; align-items: stretch; } .hsm-url-group .form-control { flex: 1; min-width: 0; margin: 0; background: var(--bs-secondary-bg, #f8f9fa); border-color: var(--bs-border-color, #dee2e6); border-top-right-radius: 0; border-bottom-right-radius: 0; height: 42px; } .hsm-url-group .btn { flex: 0 0 auto; margin: 0; margin-left: -1px; border-top-left-radius: 0; border-bottom-left-radius: 0; height: 42px; display: flex; align-items: center; justify-content: center; padding: 0 1.25rem; z-index: 2; } [data-bs-theme="dark"] .hsm-url-group .form-control { background: #0f172a; border-color: #334155; color: #e2e8f0; } .hsm-share-grid { display: flex; flex-direction: column; gap: 0.5rem; } .hsm-share-grid .btn { display: flex; align-items: center; justify-content: center; font-size: 0.9rem; padding: 0.6rem; border-color: var(--bs-border-color); width: 100%; } [data-bs-theme="dark"] .hsm-share-grid .btn { color: #e2e8f0; border-color: #475569; } [data-bs-theme="dark"] .hsm-share-grid .btn:hover { background: #334155; border-color: #cbd5e1; } </style> <script> (function(){ const modal = document.getElementById('headingShareModal'); if(!modal) return; const input = modal.querySelector('#headingShareInput'); const copyBtn = modal.querySelector('.hsm-copy'); const twitter = modal.querySelector('#share-twitter'); const linkedin = modal.querySelector('#share-linkedin'); const facebook = modal.querySelector('#share-facebook'); const closeBtn = modal.querySelector('.hsm-close'); let lastFocus=null; let trapBound=false; function buildUrl(id){ return window.location.origin + window.location.pathname + '#' + id; } function isOpen(){ return !modal.hasAttribute('hidden'); } function hydrate(id){ const url=buildUrl(id); input.value=url; const enc=encodeURIComponent(url); const text=encodeURIComponent(document.title); if(twitter) twitter.href=`https://twitter.com/intent/tweet?url=${enc}&text=${text}`; if(linkedin) linkedin.href=`https://www.linkedin.com/sharing/share-offsite/?url=${enc}`; if(facebook) facebook.href=`https://www.facebook.com/sharer/sharer.php?u=${enc}`; } function openModal(id){ lastFocus=document.activeElement; hydrate(id); if(!isOpen()){ modal.removeAttribute('hidden'); } requestAnimationFrame(()=>{ input.focus(); }); trapFocus(); } function closeModal(){ if(!isOpen()) return; modal.setAttribute('hidden',''); if(lastFocus && typeof lastFocus.focus==='function') lastFocus.focus(); } function copyCurrent(){ try{ navigator.clipboard.writeText(input.value).then(()=>feedback(true),()=>fallback()); } catch(e){ fallback(); } } function fallback(){ input.select(); try{ document.execCommand('copy'); feedback(true);}catch(e){ feedback(false);} } function feedback(ok){ if(!copyBtn) return; const icon=copyBtn.querySelector('i'); if(!icon) return; const prev=copyBtn.getAttribute('data-prev')||icon.className; if(!copyBtn.getAttribute('data-prev')) copyBtn.setAttribute('data-prev',prev); icon.className= ok ? 'fa-duotone fa-clipboard-check':'fa-duotone fa-circle-exclamation'; setTimeout(()=>{ icon.className=prev; },1800); } function handleShareClick(e){ e.preventDefault(); const btn=e.currentTarget; const id=btn.getAttribute('data-share-target'); if(id) openModal(id); } function bindShareButtons(){ document.querySelectorAll('.h-share').forEach(btn=>{ if(!btn.dataset.hShareBound){ btn.addEventListener('click', handleShareClick); btn.dataset.hShareBound='1'; } }); } bindShareButtons(); if(document.readyState==='loading'){ document.addEventListener('DOMContentLoaded', bindShareButtons); } else { requestAnimationFrame(bindShareButtons); } document.addEventListener('click', function(e){ const shareBtn=e.target.closest && e.target.closest('.h-share'); if(shareBtn && !shareBtn.dataset.hShareBound){ handleShareClick.call(shareBtn, e); } }, true); document.addEventListener('click', e=>{ if(e.target===modal) closeModal(); if(e.target.closest && e.target.closest('.hsm-close')){ e.preventDefault(); closeModal(); } if(copyBtn && (e.target===copyBtn || (e.target.closest && e.target.closest('.hsm-copy')))) { e.preventDefault(); copyCurrent(); } }); document.addEventListener('keydown', e=>{ if(e.key==='Escape' && isOpen()) closeModal(); }); function trapFocus(){ if(trapBound) return; trapBound=true; modal.addEventListener('keydown', f=>{ if(f.key==='Tab' && isOpen()){ const focusable=[...modal.querySelectorAll('a[href],button,input,textarea,select,[tabindex]:not([tabindex="-1"])')].filter(el=>!el.hasAttribute('disabled')); if(!focusable.length) return; const first=focusable[0]; const last=focusable[focusable.length-1]; if(f.shiftKey && document.activeElement===first){ f.preventDefault(); last.focus(); } else if(!f.shiftKey && document.activeElement===last){ f.preventDefault(); first.focus(); } } }); } if(closeBtn) closeBtn.addEventListener('click', e=>{ e.preventDefault(); closeModal(); }); })(); </script>A modern async Python client for Geode graph database with QUIC + TLS 1.3 (default) or gRPC transport, query builders, and connection pooling. <h3 id="installation" class="position-relative d-flex align-items-center group"> Installation <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="installation" aria-haspopup="dialog" aria-label="Share link: Installation"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">pip install geode-client </code></pre></div> <h3 id="requirements" class="position-relative d-flex align-items-center group"> Requirements <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="requirements" aria-haspopup="dialog" aria-label="Share link: Requirements"> Share link </button> </h3><ul> <li>Python 3.9+</li> <li>aioquic >= 0.9.0 (QUIC transport)</li> <li>protobuf >= 4.21.0 (wire format)</li> <li>grpcio >= 1.50.0 (gRPC transport)</li> <li>Geode server with QUIC or gRPC enabled</li> </ul> <h3 id="quick-start" class="position-relative d-flex align-items-center group"> Quick Start <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="quick-start" aria-haspopup="dialog" aria-label="Share link: Quick Start"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">import asyncio from geode_client import Client async def main(): client = Client(host="127.0.0.1", port=3141, skip_verify=True) async with client.connection() as conn: page, _ = await conn.query("RETURN 1 AS x, 'Hello' AS greeting") for row in page.rows: x = row["x"].as_int greeting = row["greeting"].as_string print(f"x={x}, greeting={greeting}") asyncio.run(main()) </code></pre></div> <h3 id="url-connection-helper" class="position-relative d-flex align-items-center group"> URL Connection Helper <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="url-connection-helper" aria-haspopup="dialog" aria-label="Share link: URL Connection Helper"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import open_database client = open_database("quic://localhost:3141?insecure_tls_skip_verify=true") async with client.connection() as conn: page, _ = await conn.query("MATCH (n) RETURN n LIMIT 10") </code></pre></div> <h4 id="grpc-transport" class="position-relative d-flex align-items-center group"> gRPC Transport <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="grpc-transport" aria-haspopup="dialog" aria-label="Share link: gRPC Transport"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import open_database client = open_database("grpc://localhost:50051") </code></pre></div><blockquote> Note (v0.3.19+): The gRPC transport now properly handles server-streaming responses. The Execute RPC streams a schema message followed by one or more data pages; earlier versions only read the first message, returning correct column metadata but empty rows. Upgrade to 0.3.19 or later for complete query results over gRPC. </blockquote> <h5 id="tls-with-self-signed-certificates" class="position-relative d-flex align-items-center group"> TLS with Self-Signed Certificates <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="tls-with-self-signed-certificates" aria-haspopup="dialog" aria-label="Share link: TLS with Self-Signed Certificates"> Share link </button> </h5>When <code>skip_verify=True</code> is set and the server uses a self-signed certificate, the gRPC transport automatically extracts the certificate’s Common Name (CN) and uses it for <code>ssl_target_name_override</code>. This means the hostname override matches the cert’s CN (e.g. <code>geode.local</code>) rather than the connection hostname, so TLS negotiation succeeds without additional configuration. <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># skip_verify trusts the server cert and derives the hostname override from its CN client = Client(host="10.0.0.5", port=50051, transport="grpc", skip_verify=True) </code></pre></div> <h3 id="dsn-format" class="position-relative d-flex align-items-center group"> DSN Format <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="dsn-format" aria-haspopup="dialog" aria-label="Share link: DSN Format"> Share link </button> </h3><blockquote> Note: See the official <a href="/docs/reference/dsn/" >DSN specification</a> for complete details. </blockquote> <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-text" data-lang="text">quic://[username:password@]host[:port][?options] # QUIC transport (default port: 3141) grpc://[username:password@]host[:port][?options] # gRPC transport (default port: 50051) host:port # Scheme-less (defaults to QUIC) </code></pre></div> <h3 id="querying" class="position-relative d-flex align-items-center group"> Querying <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="querying" aria-haspopup="dialog" aria-label="Share link: Querying"> Share link </button> </h3> <h4 id="parameterized-queries" class="position-relative d-flex align-items-center group"> Parameterized Queries <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="parameterized-queries" aria-haspopup="dialog" aria-label="Share link: Parameterized Queries"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async with client.connection() as conn: query = "MATCH (p:Person {name: $name}) RETURN p.age AS age" params = {"name": "Alice"} page, _ = await conn.query(query, params) age = page.rows[0]["age"].as_int print(f"Alice is {age} years old") </code></pre></div> <h4 id="query-builder" class="position-relative d-flex align-items-center group"> Query Builder <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="query-builder" aria-haspopup="dialog" aria-label="Share link: Query Builder"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import QueryBuilder query_text, params = ( QueryBuilder() .match("(p:Person {name: $name})-[:KNOWS]->(friend:Person)") .where("friend.age > 25") .return_("friend.name AS name", "friend.age AS age") .order_by("friend.age DESC") .limit(10) .with_param("name", "Alice") .build() ) page, _ = await conn.query(query_text, params) </code></pre></div> <h4 id="pattern-builder" class="position-relative d-flex align-items-center group"> Pattern Builder <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="pattern-builder" aria-haspopup="dialog" aria-label="Share link: Pattern Builder"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import PatternBuilder, EdgeDirection pattern = ( PatternBuilder() .node("a", "Person", {"name": "$person1"}) .edge("knows", "KNOWS", EdgeDirection.UNDIRECTED) .variable_length(1, 6) .node("b", "Person", {"name": "$person2"}) .build() ) </code></pre></div> <h4 id="predicate-builder" class="position-relative d-flex align-items-center group"> Predicate Builder <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="predicate-builder" aria-haspopup="dialog" aria-label="Share link: Predicate Builder"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import PredicateBuilder predicate = ( PredicateBuilder() .greater_than("p.age", "25") .is_not_null("p.email") .in_("p.role", ["admin", "user"]) .build_and() ) </code></pre></div> <h3 id="transactions" class="position-relative d-flex align-items-center group"> Transactions <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="transactions" aria-haspopup="dialog" aria-label="Share link: Transactions"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async with client.connection() as conn: await conn.begin() try: await conn.execute( "CREATE (p:Person {name: $name, age: $age})", {"name": "Bob", "age": 30} ) await conn.commit() except Exception: await conn.rollback() raise </code></pre></div> <h4 id="savepoints" class="position-relative d-flex align-items-center group"> Savepoints <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="savepoints" aria-haspopup="dialog" aria-label="Share link: Savepoints"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async with client.connection() as conn: await conn.begin() await conn.execute("CREATE (p:Person {name: 'Alice', age: 30})") sp = await conn.savepoint("before_update") await conn.execute("MATCH (p:Person {name: 'Alice'}) SET p.age = 40") await conn.rollback_to(sp) await conn.commit() </code></pre></div> <h3 id="prepared-statements" class="position-relative d-flex align-items-center group"> Prepared Statements <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="prepared-statements" aria-haspopup="dialog" aria-label="Share link: Prepared Statements"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">stmt = await conn.prepare("MATCH (p:Person {name: $name}) RETURN p") async with stmt: page, _ = await stmt.execute({"name": "Alice"}) </code></pre></div> <h3 id="connection-pooling" class="position-relative d-flex align-items-center group"> Connection Pooling <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="connection-pooling" aria-haspopup="dialog" aria-label="Share link: Connection Pooling"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import ConnectionPool pool = ConnectionPool( host="localhost", port=3141, min_size=2, max_size=10, timeout=30.0, page_size=1000, ) async with pool: async with pool.acquire() as conn: page, _ = await conn.query("MATCH (n) RETURN count(n) AS count") print(page.rows[0]["count"].as_int) </code></pre></div> <h3 id="authentication" class="position-relative d-flex align-items-center group"> Authentication <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="authentication" aria-haspopup="dialog" aria-label="Share link: Authentication"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import AuthClient async with client.connection() as conn: auth = AuthClient(conn) session = await auth.login("admin", "secret") print(session.token) </code></pre></div> <h3 id="type-system" class="position-relative d-flex align-items-center group"> Type System <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="type-system" aria-haspopup="dialog" aria-label="Share link: Type System"> Share link </button> </h3>Geode values are returned as <code>Value</code> objects. <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from geode_client import Value page, _ = await conn.query("RETURN 42 AS answer") value: Value = page.rows[0]["answer"] print(value.as_int) </code></pre></div> <h3 id="repository" class="position-relative d-flex align-items-center group"> Repository <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="repository" aria-haspopup="dialog" aria-label="Share link: Repository"> Share link </button> </h3><ul> <li>GitLab: <a href="https://gitlab.com/devnw/codepros/geode/geode-client-python" aria-label="devnw/codepros/geode/geode-client-python – opens in new window" target="_blank" rel="noopener noreferrer" >devnw/codepros/geode/geode-client-python ↗ </a> </li> <li>PyPI: <a href="https://pypi.org/project/geode-client/" aria-label="geode-client – opens in new window" target="_blank" rel="noopener noreferrer" >geode-client ↗ </a> </li> </ul>