get_weekly_solana_trading_volume_by_dex
Access weekly trading volume data for decentralized exchanges (DEXs) on Solana. Fetches and formats data into a pivot table with dates as rows and DEX projects as columns for clear analysis.
Instructions
Retrieve weekly trading volume by decentralized exchange (DEX) on the Solana blockchain.
This tool fetches weekly trading volume data for DEXs on Solana from a Dune Analytics query and returns it in a markdown-formatted pivot table, with dates as the index and DEX projects as columns.
Args:
limit (int, optional): Maximum number of rows to retrieve from the query. Defaults to 1000.
Returns:
str: A markdown-formatted pivot table of trading volume data, or an error message if the query fails.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| limit | No |
Implementation Reference
- main.py:197-218 (handler)The handler function for the 'get_weekly_solana_trading_volume_by_dex' tool. Decorated with @mcp.tool() for registration. Fetches data from Dune query ID 3084516, processes into a pivot table using pandas, and returns markdown.@mcp.tool() def get_weekly_solana_trading_volume_by_dex(limit: int = 1000) -> str: """ Retrieve weekly trading volume by decentralized exchange (DEX) on the Solana blockchain. This tool fetches weekly trading volume data for DEXs on Solana from a Dune Analytics query and returns it in a markdown-formatted pivot table, with dates as the index and DEX projects as columns. Args: limit (int, optional): Maximum number of rows to retrieve from the query. Defaults to 1000. Returns: str: A markdown-formatted pivot table of trading volume data, or an error message if the query fails. """ try: data = get_latest_result(3084516, limit=limit) df = pd.DataFrame(data) df["date"] = pd.to_datetime(df["time"]).dt.date pivot_df = df.pivot(index="date", columns="project", values="amount_usd") pivot_df = pivot_df.sort_index(ascending=False) return pivot_df.to_markdown() except Exception as e: return str(e)
- main.py:21-43 (helper)Shared helper function that fetches the latest execution results from a specified Dune Analytics query ID, used by this tool (query 3084516) and others.def get_latest_result(query_id: int, limit: int = 1000) -> list: """ Fetch the latest results from a Dune Analytics query. Args: query_id (int): The ID of the Dune query to fetch results from. limit (int, optional): Maximum number of rows to return. Defaults to 1000. Returns: list: A list of dictionaries containing the query results, or an empty list if the request fails. Raises: httpx.HTTPStatusError: If the API request fails due to a client or server error. """ url = f"{BASE_URL}/query/{query_id}/results" params = {"limit": limit} with httpx.Client() as client: response = client.get(url, params=params, headers=HEADERS, timeout=300) response.raise_for_status() data = response.json() result_data = data.get("result", {}).get("rows", []) return result_data