Search Nodes
search_nodesFind nodes in the knowledge graph by matching entity names, types, and observation content against a search query.
Instructions
Search for nodes in the knowledge graph based on a query
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| query | Yes | The search query to match against entity names, types, and observation content |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| entities | Yes | ||
| relations | Yes |
Implementation Reference
- The actual implementation of the search_nodes logic, which queries the database for entities matching the query and retrieves their related nodes.
async def search_nodes(self, query: str) -> Dict[str, List[Dict[str, Any]]]: """Search for nodes and their relations.""" if not query: raise ValueError("Search query cannot be empty") async with self.pool.get_connection() as conn: search_pattern = f"%{sanitize_input(query)}%" # Search entities cursor = await conn.execute( """ SELECT * FROM entities WHERE name LIKE ? OR entity_type LIKE ? OR observations LIKE ? """, (search_pattern, search_pattern, search_pattern) ) rows = await cursor.fetchall() entities = [] entity_names = set() for row in rows: entity = Entity( name=row['name'], entityType=row['entity_type'], observations=row['observations'].split(',') if row['observations'] else [] ) entities.append(entity.to_dict()) entity_names.add(entity.name) relations = await self._get_relations_for_entities(conn, entity_names) return {"entities": entities, "relations": relations}