Function extract_json_from_cluster

_cluster_utils.py:72–99

(s:str)

    logger.warning("No complete JSON object found in the input string.")
    return None
def extract_json_from_cluster(s:str):
    import re
    s=s.replace('*', '')
    entity_name = re.search(r"Aggregate Entity Name:\s*(.+)", s).group(1).strip()
    entity_description = re.search(
        r"Aggregate Entity Description:\s*(.+?)\n\nFindings:", s, re.DOTALL
    ).group(1).strip()

    # 提取 findings
    pattern = r"<summary_(\d+)>:\s*(.*?)\s*<explanation_\1>:\s*(.*?)(?=\n<summary_\d+>:|\Z)"
    matches = re.findall(pattern, s, re.DOTALL)

    findings = []
    for _, summary, explanation in matches:
        findings.append({
            "summary": summary.strip().replace('\n', ' '),
            "explanation": explanation.strip().replace('\n', ' ')
        })

    # 构造最终 JSON
    result = {
        "entity_name": entity_name,
        "entity_description": entity_description,
        "findings": findings
    }

    # 输出 JSON 字符串（可选择写入文件）
    return result
def parse_value(value: str):
    """Convert a string value to its appropriate type (int, float, bool, None, or keep as string). Work as a more broad 'eval()'"""
    value = value.strip()