strands langfuse demo

Author: networkandcode

.gitignore

@@ -3,3 +3,8 @@ _site
 .jekyll-cache
 .jekyll-metadata
 vendor
+
+**/.DS_Store
+**/.env
+**/__pycache__
+**/.venv

strands-examples/app.py

@@ -0,0 +1,58 @@
+import asyncio
+from dotenv import load_dotenv
+import time
+
+from strands import Agent
+import streamlit as st
+
+load_dotenv()
+
+async def main():
+
+    agent = Agent(
+        callback_handler=None,
+        model="us.amazon.nova-micro-v1:0",
+    )
+
+    st.title("Strands App")
+
+    if 'messages' not in st.session_state:
+        st.session_state['messages'] = []
+
+    for message in st.session_state['messages']:
+        role = message["role"]
+        content = message["content"]
+
+        with st.chat_message(role):
+            st.markdown(content)
+
+    if prompt := st.chat_input("How can I help you..."):
+        messages = []
+        with st.chat_message("user"):
+            st.markdown(prompt)
+            messages.append(
+                {
+                    "role": "user",
+                    "content": prompt,
+                }
+            )
+
+        with st.chat_message("assistant"):
+            result = ""
+            stream = agent.stream_async(prompt)
+            placeholder = st.empty()
+            async for chunk in stream:
+                if 'data' in chunk:
+                    result += chunk['data']
+                    placeholder.markdown(result)
+                    time.sleep(0.05)
+
+            messages.append(
+                {
+                    "role": "assistant",
+                    "content": result,
+                }
+            )
+        st.session_state['messages'] += messages
+
+asyncio.run(main())

strands-examples/k3s.yaml

@@ -0,0 +1,19 @@
+apiVersion: v1
+clusters:
+- cluster:
+    certificate-authority-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJkekNDQVIyZ0F3SUJBZ0lCQURBS0JnZ3Foa2pPUFFRREFqQWpNU0V3SHdZRFZRUUREQmhyTTNNdGMyVnkKZG1WeUxXTmhRREUzTlRZd016WTRORFV3SGhjTk1qVXdPREkwTVRJd01EUTFXaGNOTXpVd09ESXlNVEl3TURRMQpXakFqTVNFd0h3WURWUVFEREJock0zTXRjMlZ5ZG1WeUxXTmhRREUzTlRZd016WTRORFV3V1RBVEJnY3Foa2pPClBRSUJCZ2dxaGtqT1BRTUJCd05DQUFTYzhSK0QzazhobHlKeVNZSVFtS0lPTS80V2d2SldTa25WU2t4MXNyTmkKc3lQMXEwR3ZRaHYwNWNhaVl3cTdrQzBuRUt2T0R4ZDR1U2QxOVAvbTFFeGxvMEl3UURBT0JnTlZIUThCQWY4RQpCQU1DQXFRd0R3WURWUjBUQVFIL0JBVXdBd0VCL3pBZEJnTlZIUTRFRmdRVXFuRGZhVS96ZjBNTFdJRm1WKzJICkdLZHZrSW93Q2dZSUtvWkl6ajBFQXdJRFNBQXdSUUlnSE5WTFNvSGN3RjlsdEFhTTUrc0ROb2dFMjRta0Y4UDYKRk1zQTRjdTRPMDBDSVFDb3liZnQ1VFJOYmIwWjB2azNKTGk5dU5sSVZCU1dxdHdLMm5JRVBseTJPQT09Ci0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0K
+    server: https://127.0.0.1:6443
+  name: default
+contexts:
+- context:
+    cluster: default
+    user: default
+  name: default
+current-context: default
+kind: Config
+preferences: {}
+users:
+- name: default
+  user:
+    client-certificate-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJrVENDQVRlZ0F3SUJBZ0lJTC8zZnREWHg5ejB3Q2dZSUtvWkl6ajBFQXdJd0l6RWhNQjhHQTFVRUF3d1kKYXpOekxXTnNhV1Z1ZEMxallVQXhOelUyTURNMk9EUTFNQjRYRFRJMU1EZ3lOREV5TURBME5Wb1hEVEkyTURneQpOREV5TURBME5Wb3dNREVYTUJVR0ExVUVDaE1PYzNsemRHVnRPbTFoYzNSbGNuTXhGVEFUQmdOVkJBTVRESE41CmMzUmxiVHBoWkcxcGJqQlpNQk1HQnlxR1NNNDlBZ0VHQ0NxR1NNNDlBd0VIQTBJQUJBMXRMUXFnRHFnTC85NW4KTm1IWmJhYkxvcjNHcXhlT25iRUJ0RkRhZ3d2TmQ5Q0RKVGlvVklkQWVoYUVJcU5yRE83cW8rUGlYQTY5cVdUWApNZTVJNVptalNEQkdNQTRHQTFVZER3RUIvd1FFQXdJRm9EQVRCZ05WSFNVRUREQUtCZ2dyQmdFRkJRY0RBakFmCkJnTlZIU01FR0RBV2dCUUg0aEZTWEJTTjNjdmVyOE85WnlvQmhoUHFLVEFLQmdncWhrak9QUVFEQWdOSUFEQkYKQWlBNDQ1S1BFS3hHNUVwcE5TOFlFb0FIYWdEWXNRNXJFdkI1eVMyazhtbjl0d0loQUlGa1hVSXVEOFVOS0FiUwpTQXk0NjhLQVB2MUNVN3F1SkJHQVVra2xZSk1SCi0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0KLS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJkekNDQVIyZ0F3SUJBZ0lCQURBS0JnZ3Foa2pPUFFRREFqQWpNU0V3SHdZRFZRUUREQmhyTTNNdFkyeHAKWlc1MExXTmhRREUzTlRZd016WTRORFV3SGhjTk1qVXdPREkwTVRJd01EUTFXaGNOTXpVd09ESXlNVEl3TURRMQpXakFqTVNFd0h3WURWUVFEREJock0zTXRZMnhwWlc1MExXTmhRREUzTlRZd016WTRORFV3V1RBVEJnY3Foa2pPClBRSUJCZ2dxaGtqT1BRTUJCd05DQUFSRXBzMUZzN3dhSDVUSmxBbk9KY01LVEh3QzdwL0JxRGtWYVpuOHR3YksKWVJ6cEVtUWJiNHpOY3FRd3l0bEtiMTk0MlRYRU42eHFKOUNUSnhCRkczOC9vMEl3UURBT0JnTlZIUThCQWY4RQpCQU1DQXFRd0R3WURWUjBUQVFIL0JBVXdBd0VCL3pBZEJnTlZIUTRFRmdRVUIrSVJVbHdVamQzTDNxL0R2V2NxCkFZWVQ2aWt3Q2dZSUtvWkl6ajBFQXdJRFNBQXdSUUlnSWpjaitqcTU4NldSb3dIOGF2WDJ0Qm5pdk83T25MREkKYkZ2OG1EZUtWeW9DSVFDZjVxSUQvY3phN0JHMnYrWkRkUDY3aHZneFVDU3R3TWprcUVUQ0FPWEpWUT09Ci0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0K
+    client-key-data: LS0tLS1CRUdJTiBFQyBQUklWQVRFIEtFWS0tLS0tCk1IY0NBUUVFSUVBQk1pODZZZlhnKzkxKzg2MDJNaTFpVkVGQVpTbitEM053MWdNRllSekdvQW9HQ0NxR1NNNDkKQXdFSG9VUURRZ0FFRFcwdENxQU9xQXYvM21jMllkbHRwc3VpdmNhckY0NmRzUUcwVU5xREM4MTMwSU1sT0toVQpoMEI2Rm9RaW8yc003dXFqNCtKY0RyMnBaTmN4N2tqbG1RPT0KLS0tLS1FTkQgRUMgUFJJVkFURSBLRVktLS0tLQo=

strands-examples/k8s_mcp_agent.py

@@ -0,0 +1,62 @@
+from dotenv import load_dotenv
+import re
+
+from mcp import stdio_client, StdioServerParameters
+from strands import Agent
+from strands.tools.mcp import MCPClient
+import streamlit as st
+
+def remove_html_tags(text_with_html):
+    text_with_out_html = re.sub(r"<[^>]+>", "", text_with_html)
+    return text_with_out_html
+
+async def stream_result(stream):
+    result = ""
+    placeholder = st.empty()
+    async for chunk in stream:
+        if 'data' in chunk:
+            result += chunk['data']
+            result = remove_html_tags(result)
+            placeholder.write(result)
+
+
+class KubernetesMCPAgent:
+    def __init__(self):
+        load_dotenv()
+
+        server_params = {
+            "command": "npx",
+            "args": [
+                "-y",
+                "kubernetes-mcp-server@latest"
+            ],
+            "env": {
+                "KUBECONFIG": "k3s.yaml"
+            }
+        }
+        
+        self.stdio_mcp_client = MCPClient(lambda: stdio_client(
+            StdioServerParameters(
+                **server_params
+            )
+        ))
+
+        with self.stdio_mcp_client:
+            # Get the tools from the MCP server
+            tools = self.stdio_mcp_client.list_tools_sync()
+
+            # Create an agent with these tools
+            self.agent = Agent(
+                callback_handler=None,
+                model="us.amazon.nova-micro-v1:0",
+                tools=tools
+            )
+
+    
+    async def send_prompt(self, prompt):
+        with self.stdio_mcp_client:
+            stream = self.agent.stream_async(prompt)
+            await stream_result(stream)
+
+
+kubernetes_mcp_agent = KubernetesMCPAgent()

strands-examples/k8s_mcp_app.py

@@ -0,0 +1,14 @@
+import asyncio
+import streamlit as st
+from k8s_mcp_agent import kubernetes_mcp_agent
+
+async def main():
+    st.title("Kubernetes MCP App")
+
+    if prompt := st.chat_input("Chat with the Kubernetes API through MCP"):
+        with st.chat_message("user"):
+            st.write(prompt)
+        with st.chat_message("assistant"):
+            await kubernetes_mcp_agent.send_prompt(prompt)
+
+asyncio.run(main())

strands-examples/requirements.txt

@@ -0,0 +1,5 @@
+python-dotenv==1.1.1
+starlette==0.47.2
+strands-agents[litellm]==1.0.1
+strands-agents-tools==0.2.1
+streamlit==1.47.1

strands-examples/result.md

@@ -0,0 +1,9 @@
+Here are the current times in the 5 different countries:
+
+1. United States (Pacific Time): **2025-07-27T07:56:32.478020-07:00**
+2. United Kingdom (Greenwich Mean Time): **2025-07-27T15:56:32.477736+01:00**
+3. Japan (Japan Standard Time): **2025-07-27T23:56:32.478141+09:00**
+4. Australia (Australian Eastern Standard Time): **2025-07-28T00:56:32.477883+10:00**
+5. Brazil (Brazil Standard Time): **2025-07-27T11:56:32.478582-03:00**
+
+Please note that these times are based on the specified timezones.

strands-examples/strands-langfuse-demo/.python-version

@@ -0,0 +1 @@
+3.12

strands-examples/strands-langfuse-demo/README.md

@@ -0,0 +1,19 @@
+apiVersion: v1
+clusters:
+- cluster:
+    certificate-authority-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJlRENDQVIyZ0F3SUJBZ0lCQURBS0JnZ3Foa2pPUFFRREFqQWpNU0V3SHdZRFZRUUREQmhyTTNNdGMyVnkKZG1WeUxXTmhRREUzTlRZek1ESTJNVEV3SGhjTk1qVXdPREkzTVRNMU1ERXhXaGNOTXpVd09ESTFNVE0xTURFeApXakFqTVNFd0h3WURWUVFEREJock0zTXRjMlZ5ZG1WeUxXTmhRREUzTlRZek1ESTJNVEV3V1RBVEJnY3Foa2pPClBRSUJCZ2dxaGtqT1BRTUJCd05DQUFRbktxSVlnMXRQaERzNTJST0dTVXl5K2s5V1NTYUQ2TFV2QkttV3RQV1MKOWN5Y3dtTkMrRERKM1ZFbnc5VmJ3SHhVSnduZ1ByN1pXQitCbzBwZEJ1Zk9vMEl3UURBT0JnTlZIUThCQWY4RQpCQU1DQXFRd0R3WURWUjBUQVFIL0JBVXdBd0VCL3pBZEJnTlZIUTRFRmdRVWJKNHRQME5LYzF0OFNYMEFyZG84Cis3VFYvTHd3Q2dZSUtvWkl6ajBFQXdJRFNRQXdSZ0loQUl0VkNXSTgxSVdWOENRaEhQMlgrL013MW5pWVlTT3EKRFRqa0RxRVhtbHlWQWlFQTIxY04vUnBnV21zbWs0ajRQenJ6d1IyZlFxTjdjTzJtd3Z4NWtSTE1ZbnM9Ci0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0K
+    server: https://127.0.0.1:6443
+  name: default
+contexts:
+- context:
+    cluster: default
+    user: default
+  name: default
+current-context: default
+kind: Config
+preferences: {}
+users:
+- name: default
+  user:
+    client-certificate-data: LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJrVENDQVRlZ0F3SUJBZ0lJSFRZa2lPdmVwNzh3Q2dZSUtvWkl6ajBFQXdJd0l6RWhNQjhHQTFVRUF3d1kKYXpOekxXTnNhV1Z1ZEMxallVQXhOelUyTXpBeU5qRXhNQjRYRFRJMU1EZ3lOekV6TlRBeE1Wb1hEVEkyTURneQpOekV6TlRBeE1Wb3dNREVYTUJVR0ExVUVDaE1PYzNsemRHVnRPbTFoYzNSbGNuTXhGVEFUQmdOVkJBTVRESE41CmMzUmxiVHBoWkcxcGJqQlpNQk1HQnlxR1NNNDlBZ0VHQ0NxR1NNNDlBd0VIQTBJQUJJMS8yclR1MGJveWZwMnMKMFVBM1N1K1ZkSFpGN0hnWGE0VHd3cXJSVm4wYVBNTzZncnVPOTlRSGtJNUNNTTZlV2hsWkZ3WUI0Vlp3cndUUAp6dnVBTDB5alNEQkdNQTRHQTFVZER3RUIvd1FFQXdJRm9EQVRCZ05WSFNVRUREQUtCZ2dyQmdFRkJRY0RBakFmCkJnTlZIU01FR0RBV2dCVDNDclZmR29UZk5JelZUTm50YTFETDY3N2IwakFLQmdncWhrak9QUVFEQWdOSUFEQkYKQWlFQWpzWG1pZnljRnFXK0VYOW15NVRBZkJpT1oyL2JCRlpybEs2aytHUEJoNFlDSUgvY1dWWE1uSlBpWGR1ZwovSU9DZUVWZVJybGpGbVpqMU1DdDBrVG55YVNBCi0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0KLS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUJlRENDQVIyZ0F3SUJBZ0lCQURBS0JnZ3Foa2pPUFFRREFqQWpNU0V3SHdZRFZRUUREQmhyTTNNdFkyeHAKWlc1MExXTmhRREUzTlRZek1ESTJNVEV3SGhjTk1qVXdPREkzTVRNMU1ERXhXaGNOTXpVd09ESTFNVE0xTURFeApXakFqTVNFd0h3WURWUVFEREJock0zTXRZMnhwWlc1MExXTmhRREUzTlRZek1ESTJNVEV3V1RBVEJnY3Foa2pPClBRSUJCZ2dxaGtqT1BRTUJCd05DQUFRYlpibUhYdzIrNDlXREkvNlRSczRHaXcrSEVmQmM2UGorYzllZFpYSjgKTEpienFKMWt5ZXUzMFByeVN1RlBQV1ZJdkhEanNVYVhreGZTc1Z6V25KaTBvMEl3UURBT0JnTlZIUThCQWY4RQpCQU1DQXFRd0R3WURWUjBUQVFIL0JBVXdBd0VCL3pBZEJnTlZIUTRFRmdRVTl3cTFYeHFFM3pTTTFVelo3V3RRCnkrdSsyOUl3Q2dZSUtvWkl6ajBFQXdJRFNRQXdSZ0loQU1pdWVWYlM4VHlvL1hnSW1iT3JudTJYa3B2bVFyRDcKeWIwc0x5QTN2cHpVQWlFQXZadWw3RnlkUFdPZFFoSHIvMzVEazdvaEU1QUxaaHVaZnVISGFIb3N6L289Ci0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0K
+    client-key-data: LS0tLS1CRUdJTiBFQyBQUklWQVRFIEtFWS0tLS0tCk1IY0NBUUVFSUVtWXpXbXRlMFdicmVyNlJoNjl0T1ZVYUY4ZE5RS21KY3FTM1QwaEhiSllvQW9HQ0NxR1NNNDkKQXdFSG9VUURRZ0FFalgvYXRPN1J1akorbmF6UlFEZEs3NVYwZGtYc2VCZHJoUERDcXRGV2ZSbzh3N3FDdTQ3MwoxQWVRamtJd3pwNWFHVmtYQmdIaFZuQ3ZCTS9PKzRBdlRBPT0KLS0tLS1FTkQgRUMgUFJJVkFURSBLRVktLS0tLQo=