python: add emem geospatial memory MCP example for Streamable HTTP

python/samples/concepts/mcp/emem_mcp_geospatial_agent.py

@@ -0,0 +1,69 @@
+# Copyright (c) Microsoft. All rights reserved.
+
+"""Semantic Kernel + emem MCP example — multi-step geospatial verification.
+
+Connects a Microsoft Semantic Kernel agent to the emem MCP server over
+Streamable HTTP. For each query the agent: resolves a place to a canonical
+cell64 address, recalls signed Earth-observation facts, and reports the
+emem:fact: receipt so the answer can be verified offline.
+
+Install:
+    pip install semantic-kernel
+
+Usage:
+    export OPENAI_API_KEY="sk-..."
+    export OPENAI_CHAT_MODEL_ID="gpt-4o"   # optional, defaults to gpt-4o
+    python emem_mcp_geospatial_agent.py
+
+No API key is needed for emem — reads are anonymous (Apache 2.0).
+"""
+
+import asyncio
+import os
+
+from semantic_kernel.agents import ChatCompletionAgent, ChatHistoryAgentThread
+from semantic_kernel.connectors.ai.open_ai import OpenAIChatCompletion
+from semantic_kernel.connectors.mcp import MCPStreamableHttpPlugin
+
+EMEM_MCP_URL = os.getenv("EMEM_MCP_URL", "https://emem.dev/mcp")
+
+USER_INPUTS = [
+    (
+        "Using emem, resolve South Mumbai, recall its elevation "
+        "(copdem30m.elevation_mean), then verify the receipt/fact CID. "
+        "Show each step: locate, recall, verify."
+    ),
+    "Is the air quality in Delhi safe for outdoor exercise right now? Give me a signed fact with a receipt I can cite.",
+    "Has there been recent deforestation near the Amazon at -3.47° N, -62.22° W?",
+]
+
+
+async def main() -> None:
+    async with MCPStreamableHttpPlugin(
+        name="emem",
+        description="Shared, verifiable Earth memory — signed facts for any place on Earth",
+        url=EMEM_MCP_URL,
+    ) as emem_plugin:
+        agent = ChatCompletionAgent(
+            service=OpenAIChatCompletion(),
+            name="GeospatialAgent",
+            instructions=(
+                "You are a geospatial verification agent grounded in emem's signed Earth memory. "
+                "For every place query: "
+                "1. Use the available emem tools to resolve the place to a canonical cell64 address. "
+                "2. Use the available emem tools to read signed facts (air quality, elevation, flood extent, etc.). "
+                "3. Report the emem:fact: receipt so the user can verify it offline, including the fact_cid."
+            ),
+            plugins=[emem_plugin],
+        )
+
+        for user_input in USER_INPUTS:
+            thread = ChatHistoryAgentThread()
+            print(f"\n# User: {user_input}")
+            response = await agent.get_response(messages=user_input, thread=thread)
+            print(f"# {response.name}: {response}")
+            await thread.delete()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())