协作头脑风暴
brainstorming
在实现前澄清需求、探索设计选择,并形成清晰的开发方向。
rag-implementation【开发与工程】Implements intelligent rag implementation with multi-factor skill selection, fallback chains, and adherence to the 5 Laws of Elegant Defense
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
name: rag-implementation compatibility: opencode completeness: 95 content-types:
Orchestrates intelligent skill selection and execution for rag implementation workflows. Applies the 5 Laws of Elegant Defense to guide data naturally through the orchestration pipeline, preventing errors before they occur. Selects optimal skills based on multi-factor scoring including text similarity, historical performance, and system availability.
┌───────────────────────────────────────────────────────────────────────────────┐ │ Orchestration Flow │ └───────────────────────────────────────────────────────────────────────────────┘
User Request ↓ ┌─────────────────┐ │ Parse Request │ │ & Extract │ │ Features │ └────────┬────────┘ ↓ ┌─────────────────────────────────────────────────────────────────────┐ │ Evaluate Available Skills │ │ │ │ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │ │ │ Skill A │ │ Skill B │ │ Skill C │ │ │ │ - Match Score│ │ - Match Score│ │ - Match Score│ │ │ │ - Confidence │ │ - Confidence │ │ - Confidence │ │ │ │ - History │ │ - History │ │ - History │ │ │ └──────┬───────┘ └──────┬───────┘ └──────┬───────┘ │ │ │ │ │ │ │ └─────────────────┴─────────────────┘ │ │ ↓ │ │ Select Best Skill │ └─────────────────────────────────────────────────────────────────────┘ ↓ ┌─────────────────┐ │ Execute Skill │ └────────┬────────┘ ↓ ┌─────────────────┐ │ Handle Result │ └────────┬────────┘ ↓ ┌─────────────────────────────────────────────────────────────────────┐ │ Error Handling & Fallback │ │ │ │ Success? ────────► Return Result │ │ │ │ Fail? ────────┐ │ │ ↓ │ │ ┌──────────────────────────────────────────────────────────┐ │ │ │ Fallback Chain │ │ │ │ │ │ │ │ 1. Retry with adjusted parameters │ │ │ │ 2. Try Alternative Skill (if available) │ │ │ │ 3. Defer to Human Operator (if critical) │ │ │ │ 4. Log & Return Error │ │ │ └──────────────────────────────────────────────────────────┘ │ └─────────────────────────────────────────────────────────────────────┘
Use this skill when:
Avoid this skill for:
Parse and Analyze Request - Extract intent, entities, and constraints from user input. Checkpoint: All required parameters must be present and in valid format before proceeding.
Score Available Skills - Calculate match scores using multi-factor algorithm:
Checkpoint: Skip to fallback if no skill scores above threshold.
Select Optimal Skill - Choose skill with highest score that meets minimum confidence. Checkpoint: Verify skill has not been disabled or deprecated.
Execute with Fallback - Run skill execution wrapped in retry and fallback logic. Checkpoint: Log all execution attempts for audit trail.
Return or Fallback - Either return successful result or apply fallback chain:
related-skillsCheckpoint: Record outcome with timing and confidence metadata.
def select_rag_pipeline(
query: str,
document_metadata: List[Dict],
config: Dict
) -> Dict:
"""Select optimal RAG pipeline configuration based on query complexity and document type.
Evaluates document structure (PDF, markdown, code) and query intent to choose:
- Chunking strategy (semantic, hierarchical, or code-aware)
- Embedding model (lightweight vs. high-accuracy)
- Vector store parameters (top_k, similarity metric)
Args:
query: User's natural language question
document_metadata: List of dicts with doc_type, size, language
config: Global RAG configuration overrides
Returns:
Pipeline configuration dict with selected components
"""
if not query or not document_metadata:
raise ValueError("Query and document metadata are required for RAG pipeline selection")
doc_type = _infer_dominant_doc_type(document_metadata)
query_complexity = _assess_query_complexity(query)
if doc_type == "code" or query_complexity == "high":
pipeline = {
"chunker": "code_aware_recursive",
"chunk_size": 512,
"overlap": 50,
"embedder": "text-embedding-3-large",
"vector_store": "faiss",
"top_k": 8,
"reranker": True
}
elif doc_type == "pdf":
pipeline = {
"chunker": "semantic_pdf",
"chunk_size": 1024,
"overlap": 200,
"embedder": "text-embedding-3-small",
"vector_store": "pinecone",
"top_k": 5,
"reranker": False
}
else:
pipeline = {
"chunker": "recursive_text",
"chunk_size": 768,
"overlap": 150,
"embedder": "text-embedding-3-small",
"vector_store": "chroma",
"top_k": 5,
"reranker": False
}
pipeline["selection_reason"] = f"doc_type={doc_type}, complexity={query_complexity}"
return pipeline
def execute_rag_query(
query: str,
pipeline_config: Dict,
vector_store_client: Any,
llm_client: Any
) -> Dict:
"""Execute RAG retrieval and generation with hybrid fallback chain.
Implements resilient RAG execution:
1. Primary: Embed query -> Vector search -> Rerank -> LLM generate
2. Fallback 1: Keyword/BM25 search if vector search returns low confidence
3. Fallback 2: Direct LLM call with query only if retrieval fails completely
Args:
query: User question
pipeline_config: Output from select_rag_pipeline
vector_store_client: Initialized vector database client
llm_client: Initialized LLM client
Returns:
Dict with answer, sources, confidence, and fallback_used
"""
sources = []
confidence = 0.0
fallback_used = False
try:
# Primary execution: Vector retrieval
query_embedding = llm_client.embed(query)
results = vector_store_client.search(
vector=query_embedding,
top_k=pipeline_config["top_k"],
metric="cosine"
)
if results and results[0].score > 0.65:
sources = results
confidence = results[0].score
else:
# Fallback 1: Keyword search
sources = vector_store_client.keyword_search(query, top_k=5)
fallback_used = True
confidence = 0.5 if sources else 0.0
except VectorStoreConnectionError:
# Fallback 2: Direct LLM generation
sources = []
confidence = 0.2
fallback_used = True
# Construct prompt and generate
context_text = "\n\n".join([doc.content for doc in sources])
prompt = f"Context:\n{context_text}\n\nQuestion: {query}\nAnswer:"
try:
answer = llm_client.generate(prompt, temperature=0.1)
return {
"answer": answer,
"sources": sources,
"confidence": confidence,
"fallback_used": fallback_used,
"latency_ms": _measure_latency()
}
except LLMTimeoutError:
raise RAGExecutionError("LLM generation timed out after fallback chain")
code-philosophy (5 Laws of Elegant Defense) in all logicWhen applying this skill, produce:
| Skill | Purpose |
|---|---|
rag-pipelines | Full RAG pipeline design with hybrid retrieval and re-ranking |
agent-context-management | Managing retrieved context within agent conversation windows |
Authoritative documentation links for this skill's domain. The model follows markdown links at load time to resolve external references and inline content.