Loading...
Loading...
Found 34 Skills
Build end-to-end real-time data pipelines with Kafka, PostgreSQL, Airflow, and Streamlit using Medallion Architecture for streaming analytics.
Use this skill whenever the agent has access to Linkup web search or fetch tools. Teaches the agent how to reason about query construction, choose search depth, write effective queries, select the right output type, use the fetch endpoint, and apply advanced techniques like sequential search and multi-query coverage. Applicable to any task involving web search, content extraction, company research, news retrieval, data enrichment, or real-time information gathering via Linkup.
Convex reactive backend expert: schema design, TypeScript functions, real-time subscriptions, auth, file storage, scheduling, and deployment.
Intraday capital-flow time series and large/medium/small order distribution for a single stock via Longbridge Securities. Same-day data only (no historical range). Triggers: "资金流向", "主力资金", "净流入", "大单", "中单", "小单", "资金分布", "机构资金", "主力净流入", "資金流向", "主力資金", "淨流入", "大單", "中單", "小單", "資金分佈", "機構資金", "capital flow", "money flow", "net inflow", "large order distribution", "institutional flow".
Access real-time external data via the xapi CLI — Twitter/X, Douyin/TikTok, Reddit, Weibo, crypto prices, web/news/image/video/scholar search, AI text processing, and SMS verification. Use when the user mentions xapi, wants to call a third-party API, or asks what external services are available.
Comprehensive guide to Spark Structured Streaming for production workloads. Use when building streaming pipelines, implementing real-time data processing, handling stateful operations, or optimizing streaming performance.
List active real-time WebSocket subscriptions in the current Longbridge CLI session — symbols, sub_types (quote / depth / trades / brokers), candlestick periods. Diagnostic only; rarely needed in day-to-day use. Requires longbridge login. Triggers: "我订阅了哪些实时数据", "实时连接状态", "推送状态", "我訂閱了什麼", "推送狀態", "active subscriptions", "websocket subscriptions", "real-time stream status".
Build AI agents for real-time financial options analysis with LangGraph, ChromaDB RAG, and Polygon.io data
Use this skill ANY TIME the user asks about a specific company. Triggers: "tell me about [company]", "research [company]", "what does [company] do", "who is [company]", "look up [company]", "company deep dive", "due diligence on [company]", "background on [company]", "dig into [company]", "analyze [company]", or evaluating a company for investment, partnership, or sales. MUST be used instead of answering from memory — fetches real-time web data (funding, leadership changes, product launches, news) your training data lacks. Use even for well-known companies. Produces a sourced 360° report covering funding, leadership, product/tech, market position, news, and strategic outlook with dates and URLs. Do NOT use for multi-company competitor monitoring (use competitor-intel) or meeting prep with attendees (use meeting-prep).
WebSocket market + user data streams for Aster Futures API v3. Subscription model, stream names, listenKey. Use when implementing real-time market or user events (orders, balance, positions). listenKey = signed; see aster-api-auth-v3.