OceanBase seekdb

You can try seekdb in 30 seconds using the pyseekdb Python library. It works in embedded mode (no server required, schema-less) and uses an asynchronous indexing pipeline. If you need to query immediately after writing, call refresh_index() to ensure the index is prepared.

import pyseekdb

client = pyseekdb.Client(path="./agent_state.db")
memory = client.get_or_create_collection(name="episodic")

# Write observations
memory.upsert(
    ids=["1", "2", "3"],
    documents=[
        "user prefers dark mode",
        "user speaks English and Chinese",
        "user timezone is UTC+8",
    ],
)
memory.refresh_index()

# Query
results = memory.query(query_texts="ui preferences?", n_results=1)
print(results["documents"])
# -> [['user prefers dark mode']]

# Write new observation and refresh
memory.upsert(ids=["4"], documents=["user saw pricing page 3 times today"])
memory.refresh_index()

results = memory.query(query_texts="purchase intent signals", n_results=1)
print(results["documents"])
# -> [['user saw pricing page 3 times today']]

You can run seekdb in-process without a separate server. Use pyseekdb.Client to initialize a local database file, create a collection, and perform upserts and queries. Note that you must call refresh_index() to make new writes immediately queryable.

import pyseekdb

client = pyseekdb.Client(path="./agent_state.db")
memory = client.get_or_create_collection(name="episodic")

# Write Agent observations
memory.upsert(
    ids=["1", "2", "3"],
    documents=[
        "user prefers dark mode",
        "user speaks English and Chinese",
        "user timezone is UTC+8",
    ],
)
memory.refresh_index()

# Query the data
results = memory.query(query_texts="ui preferences?", n_results=1)
print(results["documents"])
# -> [['user prefers dark mode']]

# Write new observation and refresh
memory.upsert(ids=["4"], documents=["user saw pricing page 3 times today"])
memory.refresh_index()

results = memory.query(query_texts="purchase intent signals", n_results=1)
print(results["documents"])
# -> [['user saw pricing page 3 times today']]

Follow these rules for local variable management to ensure readability and performance:

Best Practices:

• Placement: Declare variables at the beginning of a statement block. If the declaration and use are far apart, refactor the block.
• Initialization: Simple variables should be initialized upon declaration.
• Loop Efficiency: Avoid declaring complex variables (e.g., class instances) inside a loop body, as this causes repeated construction/destruction. Extract them outside the loop.
  • Note: Declaring references inside a loop is allowed for readability.

Constraints:

• Stack Limit: The function stack should not exceed 32K.
• Variable Size: A single local variable should not exceed 8K.
• Complex Variables in Loops: Prohibited unless approved by a team leader with detailed comments.

// Inefficient implementation
for (int i = 0; i < 100000; ++i) {
  ObFoo f;  // Constructor/destructor called every iteration
  f.do_something();
}

// Efficient implementation
ObFoo f;
for (int i = 0; i < 100000; ++i) {
  f.do_something();
}

// References are allowed inside loops for readability
for(int i = 0; i < N; ++i) {
   const T &t = very_long_variable_name.at(i);
   t.f1();
   t.f2();
}

Debug Sync is disabled by default. Use the following SQL commands to manage its lifecycle:

1. Enable the mechanism

Set debug_sync_timeout to a value greater than 0 (unit is microseconds).

alter system set debug_sync_timeout='100000s';

2. Activate a specific sync point

Use set ob_global_debug_sync to tell a thread to wait at a specific point. Format: 'POINT_NAME wait_for signal_name execute MAX_EXECUTIONS'

set ob_global_debug_sync = 'BEFORE_UNIT_MANAGER_LOAD wait_for my_signal execute 10000';

3. Signal the thread to continue

Wake up the hanging thread using signal (single thread) or broadcast (all threads waiting on that signal).

set ob_global_debug_sync = 'now signal my_signal';
-- or
set ob_global_debug_sync = 'now broadcast my_signal';

4. Clear or Disable

To remove a specific point or disable the mechanism entirely:

-- Clear a specific point
set ob_global_debug_sync = 'BEFORE_UNIT_MANAGER_LOAD clear';

-- Disable debug sync globally
alter system set debug_sync_timeout=0;