|
14 | 14 | from fabric_rti_mcp.common import config, logger
|
15 | 15 | from fabric_rti_mcp.eventstream import eventstream_tools
|
16 | 16 | from fabric_rti_mcp.kusto import kusto_config, kusto_tools
|
| 17 | + |
17 | 18 | # Global variable to store server start time
|
18 | 19 | server_start_time = datetime.now(timezone.utc)
|
19 | 20 |
|
20 |
| -KUSTO_INSTRUCTIONS = """ |
21 |
| -- Kusto |
22 |
| - - Description: Kusto service for querying and managing data. |
23 |
| - - Guideline: |
24 |
| - - Clearly distinguish between different parts of queries (e.g. relational, graph, semantic similarity). |
25 |
| - Although they can be mixed, they have different semantics: |
26 |
| - - Relational queries focus on structured data and relationships. |
27 |
| - - Graph queries explore connections between entities. To use them you must have: |
28 |
| - - A graph reference (e.g. graph('name')) |
29 |
| - - A graph-match clause with a graph pattern (e.g. | graph-match (node)-[edge]->(target) project node, edge) |
30 |
| - - The graph-match node must have a projection clause to be valid |
31 |
| - - Semantic similarity queries assess the meaning and context of data. |
32 |
| - - Use series_cosine_similarity(vector_a, vector_b) |
33 |
| - - Don't guess schema / values. Always execute `kusto_get_entity_schema()` first, |
34 |
| - and if still unsure, use a simple query like `take 1` to understand the data. |
35 |
| -""" |
36 | 21 |
|
37 | 22 | def setup_shutdown_handler(sig: int, frame: Optional[types.FrameType]) -> None:
|
38 | 23 | """Handle process termination signals."""
|
@@ -108,13 +93,7 @@ def main() -> None:
|
108 | 93 | stateless_http=config.stateless_http,
|
109 | 94 | )
|
110 | 95 | else:
|
111 |
| - fastmcp_server = FastMCP(name, instructions=""" |
112 |
| -This server has the following services: |
113 |
| -{ki} |
114 |
| -- EventStream |
115 |
| - - Description: EventStream service for processing and managing events. |
116 |
| - - Guideline: `` |
117 |
| - """.format(ki=KUSTO_INSTRUCTIONS)) |
| 96 | + fastmcp_server = FastMCP(name) |
118 | 97 |
|
119 | 98 | # 1. Register tools
|
120 | 99 | register_tools(fastmcp_server)
|
|
0 commit comments