DifyでドキュメントからCSVデータを抽出しEChartsで可視化するツール作成ガイド

Posted at 2025-03-15

はじめに

この記事では、Difyプラットフォームを利用して、ドキュメントのテキスト抽出からCSV変換、さらにEChartsで可視化する一連のワークフローを作成する方法を解説します。Excelのドキュメントを自動で分析し、インタラクティブなダッシュボードを構築するプロセスをステップバイステップで説明します。

環境準備

Difyアカウント：アカウントを作成し、ワークスペースを準備
サンプルデータ：Excel形式の数値データを用意

チャットフローの作成

1. Difyのダッシュボードから「チャットフロー」を選択

ワークフローの名前を「ドキュメント可視化ツール」と設定

2. 入力フィールドとして「ドキュメントアップロード」コンポーネントを追加

3. テキスト抽出ツールをフローに追加

アップロードされたドキュメントからテキストを抽出する設定を行う
抽出結果をワークフロー内で次のステップに受け渡す

4. LLMによるCSV変換

#役割
あなたはデータ整理の専門家です。データ形式の整理やフォーマット変換を担当します。
#データ
{{#1742042932212.text#}}
#タスク
データをCSV形式に変換して、CSV形式で出力してください。

5. PythonスクリプトでEChartsを生成

import csv
import json


def main(csv_string):
    lines = csv_string.strip().split('\n')
    reader = csv.reader(lines)
    data = [row for row in reader]

    # 数値を変換（ヘッダ行と最初の列を除く）
    for row in data[1:]:
        for i in range(1, len(row)):
            try:
                row[i] = float(row[i])
            except ValueError:
                pass

    cols = len(data[0])
    rows = len(data) - 1

    echarts_config = {
        "legend": {},
        "tooltip": {},
        "dataset": {
            "source": data
        },
        "xAxis": [
            {
                "type": "category",
                "gridIndex": 0,
                "data": data[0][1:]  # 列のラベル（最初の列を除く）
            },
            {
                "type": "category",
                "gridIndex": 1,
                "data": [row[0] for row in data[1:]]  # 行のラベル（2行目以降の最初の列）
            }
        ],
        "yAxis": [
            {"type": "value", "gridIndex": 0},
            {"type": "value", "gridIndex": 1}
        ],
        "grid": [
            {"bottom": "55%"},
            {"top": "55%"}
        ],
        "series": []
    }

    # 行方向のバーグラフシリーズ（各データ行ごとに1つのシリーズ）
    row_series = []
    for row in data[1:]:
        row_series.append({
            "type": "bar",
            "seriesLayoutBy": "row",
            "name": row[0],
            "xAxisIndex": 0,
            "yAxisIndex": 0
        })

    # 列方向のバーグラフシリーズ（各データ列ごとに1つのシリーズ/最初の列を除く）
    col_series = []
    for col_idx in range(1, cols):
        col_series.append({
            "type": "bar",
            "seriesLayoutBy": "column",
            "name": data[0][col_idx],
            "xAxisIndex": 1,
            "yAxisIndex": 1
        })

    echarts_config["series"] = row_series + col_series

    output = "\n```echarts\n" + json.dumps(echarts_config, indent=2, ensure_ascii=False) + "\n```"
    return {"output": output}