16fc7a2598
Honeywell HC900을 Modbus TCP로 직접 폴링 → gRPC → C# 크롤러 → PostgreSQL. 기존 Experion OPC UA 데이터 경로를 HC900 직접 통신으로 대체. - industrial-comm/cpp: C++ Modbus 게이트웨이 (gRPC 서버) - src: C# .NET 8 ASP.NET Core 크롤러 + 웹 UI (3-Layer) - mcp-server: Python FastMCP (RAG/NL2SQL/P&ID) - 다중 컨트롤러(N-Controller) 지원 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
50 lines
1.7 KiB
Python
50 lines
1.7 KiB
Python
"""xlsx 청킹 — 시트 단위(markdown) + 행 단위 둘 다 생성."""
|
|
from __future__ import annotations
|
|
|
|
|
|
def parse(path: str) -> list[dict]:
|
|
from openpyxl import load_workbook
|
|
|
|
wb = load_workbook(path, read_only=True, data_only=True)
|
|
chunks: list[dict] = []
|
|
|
|
for sheet in wb.worksheets:
|
|
rows = list(sheet.iter_rows(values_only=True))
|
|
if not rows:
|
|
continue
|
|
|
|
header = [str(c) if c is not None else "" for c in rows[0]]
|
|
sheet_name = sheet.title
|
|
|
|
# 1) 시트 청크 — markdown 표 (선두 1000행 제한)
|
|
body_rows = rows[1:1001]
|
|
md_lines = ["| " + " | ".join(header) + " |",
|
|
"| " + " | ".join(["---"] * len(header)) + " |"]
|
|
for r in body_rows:
|
|
cells = [str(c) if c is not None else "" for c in r]
|
|
cells += [""] * (len(header) - len(cells))
|
|
md_lines.append("| " + " | ".join(cells[: len(header)]) + " |")
|
|
chunks.append({
|
|
"text": "\n".join(md_lines),
|
|
"chunk_kind": "sheet",
|
|
"locator": f"sheet={sheet_name}",
|
|
})
|
|
|
|
# 2) 행 청크 — 각 행을 'col=val' 형식 한 줄로
|
|
for i, r in enumerate(rows[1:], start=2):
|
|
parts = []
|
|
for j, val in enumerate(r):
|
|
if val is None or val == "":
|
|
continue
|
|
col = header[j] if j < len(header) and header[j] else f"col{j+1}"
|
|
parts.append(f"{col}={val}")
|
|
if not parts:
|
|
continue
|
|
chunks.append({
|
|
"text": f"{sheet_name}: " + ", ".join(parts),
|
|
"chunk_kind": "row",
|
|
"locator": f"sheet={sheet_name}; row={i}",
|
|
})
|
|
|
|
return chunks
|