Sign in
agent:
Auto Exec

Search and retrieve recent logs from Elasticsearch for specific services containing target keywords.

Trace-based log analysis across microservices or services in Elasticsearch for distributed request tracking using problematic trace_ids from jaeger

List my elasticsearch indices to give me an index pattern name I can search the logs for

Send comprehensive troubleshooting report with root cause and relevant details to Slack channel 'demo'

Perform preliminary infrastructure check by deriving EC2 instance ID from demo app URL, checking instance state, and verifying security group access for port 81

Summarize all recent exceptions and errors for a given set of service or services in jaeger.

Show traces in the last n minutes where service.name in a list of target service/s and (http.target or http.route or url.path contains /path_filter for eg: /api/checkout).

Identify slow or high latency traces for a given service or list of services in jaeger

List all my services in jaeger excludes system related services

Perform preliminary infrastructure check by deriving EC2 instance ID from demo app URL, checking instance state, and verifying security group access for port 81

Fetch the most recent 5 logs from the elasticsearch index <index_name> in last n minutes <lookback_minutes>

Queries Elasticsearch to fetch the latest logs from a list of specified services with required fields

Fetches the latest 10 logs from Elasticsearch for a specific service, sorted by timestamp in descending order

List my elasticsearch indices to give me an index pattern name I can search the logs for

Add a key-value pair

Add credentials for various integrations

What is an "Expert"? How do we create our own expert?

Process Grafana Alerts

Managing workspaces and access control

DagKnows Architecture Overview

Managing Proxies

Setting up SSO via Azure AD for Dagknows

All the experts

Enable "Auto Exec" and "Send Execution Result to LLM" in "Adjust Settings" if desired

(Optionally) Add ubuntu user to docker group and refresh group membership

Deployment of an EKS Cluster with Worker Nodes in AWS

Adding, Deleting, Listing DagKnows Proxy credentials or key-value pairs

Comprehensive AWS Security and Compliance Evaluation Workflow (SOC2 Super Runbook)

AWS EKS Version Update 1.29 to 1.30 via terraform

Instruction to allow WinRM connection

MSP Usecase: User Onboarding Azure + M365

Post a message to a Slack channel

How to debug a kafka cluster and kafka topics?

Docusign Integration Tasks

Open VPN Troubleshooting (Powershell)

Execute a simple task on the proxy

Assign the proxy role to a user

Create roles to access credentials in proxy

Install OpenVPN client on Windows laptop

Setup Kubernetes kubectl and Minikube on Ubuntu 22.04 LTS

Install Prometheus and Grafana on the minikube cluster on EC2 instance in the monitoring namespace

Sample selenium script

update the EKS versions in different clusters

AI agent session 2024-09-12T09:36:14-07:00 by Sarang Dharmapurikar

Install kubernetes on an ec2 instance ubuntu 20.04 using kubeadm and turn this instance into a master node.

Turn an ec2 instance, ubuntu 20.04 into a kubeadm worker node. Install necessary packages and have it join the cluster.

Install Docker

Parse EDN content and give a JSON out

GitHub related tasks

Check whether a user is there on Azure AD and if the user account status is enabled

List all my services in jaeger excludes system related services

There was a problem that the LLM was not able to address. Please rephrase your prompt and try again.

Fetches and lists all services available in Jaeger using the services API endpoint

Exclude system/non-application services from Jaeger analysis.

These create false positives or represent infrastructure traffic.

Skip all traces where process.serviceName matches:

-- jaeger-all-in-one (internal Jaeger backend)

-- flagd (long-lived feature flag streams) (false latency)

-- load-generator (synthetic load traffic)

-- "ad"# optional: often noisy / not core to checkout

-- "recommendation"# optional: can inherit external/flagd delays

--"fraud-detection" # optional: can inherit external/flagd delays

import requests import json from datetime import datetime # --- Config / Environment --- jaeger_base = getEnvVar('JAEGER_URL_OTEL') # provided by your env if not jaeger_base: raise RuntimeError("Missing env var JAEGER_URL_OTEL") # Normalize base URL (allow with/without trailing slash) if not jaeger_base.endswith('/'): jaeger_base += '/' services_url = f"{jaeger_base}services" # Exclusions: infra, synthetic traffic, and known-noisy services EXCLUDED = { "jaeger-all-in-one", # Jaeger backend itself "flagd", # long-lived event streams cause misleading latency "load-generator", # synthetic traffic "ad", # optional: often noisy / not core to checkout "recommendation", # optional: can inherit external/flagd delays "fraud-detection" } result = { "time_queried": datetime.utcnow().isoformat() + "Z", "jaeger_services_endpoint": services_url, "total_services_found": 0, "excluded_services_requested": sorted(list(EXCLUDED)), "excluded_services_present": [], "services_included": [], "service_count": 0 } try: resp = requests.get(services_url, timeout=6) resp.raise_for_status() data = resp.json() # Jaeger API returns {"data": ["svc1","svc2",...]} ; fall back to raw list if needed raw_services = data.get("data", data if isinstance(data, list) else []) raw_services = [s for s in raw_services if isinstance(s, str)] result["total_services_found"] = len(raw_services) # Which excluded are actually present present_excluded = sorted([s for s in raw_services if s in EXCLUDED]) result["excluded_services_present"] = present_excluded # Apply filter filtered = [s for s in raw_services if s not in EXCLUDED] result["services_included"] = filtered result["service_count"] = len(filtered) service_count = len(filtered) target_services = filtered except requests.exceptions.RequestException as e: result["error"] = f"Error connecting to Jaeger: {e}" result["services_included"] = [] result["service_count"] = 0 except Exception as e: result["error"] = f"Error processing Jaeger response: {e}" result["services_included"] = [] result["service_count"] = 0 # Print JSON for the job runner to capture as outputs print(json.dumps(result, indent=2))
copied