initial commit

Author: kazu5150

.gitignore

@@ -0,0 +1,21 @@
+# Environments
+.env
+.venv
+env/
+myenv/
+ENV/
+env.bak/
+venv.bak/
+
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+
+# IDEs
+.vscode/
+.idea/
+
+# OS generated files
+.DS_Store
+Thumbs.db

Dify-workflow.png

@@ -0,0 +1,105 @@
+# Dify Workflow Runner
+
+このプロジェクトは、ローカル環境にDockerでインストールしたDifyにリクエストを送信し、その応答を処理するPythonスクリプトです。
+この例では、自分のPCにDifyをインストールし、ワークフローを作成しています。
+
+
+![Difyスクリーンショット](Dify-workflow.png "Dify Workflow Runnerのスクリーンショット")
+
+
+## 概要
+
+このスクリプトは以下の機能を提供します：
+
+1. Dify APIにワークフロー実行リクエストを送信
+2. ストリーミングレスポンスを受信して処理
+3. ワークフローの実行情報と生成されたコンテンツ（詩）を整形して表示
+
+## 前提条件
+
+- Python 3.6以上
+- Docker
+- ローカル環境にインストールされたDify
+
+## セットアップ
+
+1. このリポジトリをクローンします：
+
+   ```
+   git clone https://github.com/yourusername/dify-workflow-runner.git
+   cd dify-workflow-runner
+   ```
+
+2. 必要なPythonパッケージをインストールします：
+
+   ```
+   pip install -r requirements.txt
+   ```
+
+   これにより、`requests`と`python-dotenv`を含む必要なすべての依存関係がインストールされます。
+
+3. `.env`ファイルを作成し、必要な環境変数を設定します：
+
+   ```
+   API_URL=http://localhost/v1/workflows/run
+   API_KEY=your_api_key_here
+   ```
+
+   注意: `API_KEY`は実際のDify APIキーに置き換えてください。
+
+## 使用方法
+
+スクリプトを実行するには、以下のコマンドを使用します：
+
+```
+python dify_workflow_runner.py
+```
+
+スクリプトは、Dify APIにリクエストを送信し、レスポンスを処理して結果を表示します。
+
+## 出力
+
+スクリプトは以下の情報を出力します：
+
+1. ワークフローの実行情報
+   - ワークフロー実行ID
+   - タスクID
+   - ステータス
+   - 合計トークン数
+   - 合計ステップ数
+   - 作成者ID
+   - ユーザー
+   - 作成時刻
+   - 終了時刻
+   - 実行時間
+
+2. 生成されたコンテンツ（詩）
+
+## 注意事項
+
+- このスクリプトは、ローカル環境で動作するDifyを対象としています。他の環境で使用する場合は、`API_URL`を適切に変更してください。
+- APIキーは機密情報です。`.env`ファイルをGitリポジトリにコミットしないよう注意してください。
+- 依存関係は`requirements.txt`ファイルで管理されています。新しい依存関係を追加する場合は、このファイルを更新してください。
+
+## 依存関係の更新
+
+プロジェクトの依存関係を更新する場合は、以下の手順に従ってください：
+
+1. `requirements.txt`ファイルを編集し、必要な変更を加えます。
+2. 以下のコマンドを実行して、依存関係を更新します：
+
+   ```
+   pip install -r requirements.txt --upgrade
+   ```
+
+## ライセンス
+
+[MITライセンス](LICENSE)
+
+## 貢献
+
+プルリクエストは歓迎します。大きな変更を加える場合は、まずissueを開いて変更内容を議論してください。
+
+## サポート
+
+問題や質問がある場合は、GitHubのissueを開いてください。

README.md

@@ -0,0 +1,56 @@
+import requests
+import json
+from datetime import datetime
+import os
+from dotenv import load_dotenv
+
+# .envファイルから環境変数を読み込む
+load_dotenv()
+
+
+def unix_to_datetime(unix_time):
+    return datetime.fromtimestamp(unix_time).strftime('%Y年%m月%d日 %H:%M:%S')
+
+
+# 環境変数からURLとAPIキーを取得
+url = os.getenv('API_URL')
+api_key = os.getenv('API_KEY')
+
+headers = {
+    'Authorization': f'Bearer {api_key}',
+    'Content-Type': 'application/json'
+}
+data = {
+    "inputs": {
+        "query": "Hear I go again!!"},
+    "response_mode": "streaming",
+    "user": "abc-123"
+}
+
+response = requests.post(url, headers=headers, data=json.dumps(data), stream=True)
+
+if response.status_code == 200:
+    for line in response.iter_lines():
+        if line:
+            line = line.decode('utf-8')
+            if line.startswith('data: '):
+                event_data = json.loads(line[6:])
+                if event_data['event'] == 'workflow_finished':
+                    workflow_data = event_data['data']
+
+                    print("1. ワークフローの実行情報:")
+                    print(f"   - ワークフロー実行ID: {workflow_data['id']}")
+                    print(f"   - タスクID: {event_data['task_id']}")
+                    print(f"   - ステータス: {workflow_data['status']}")
+                    print(f"   - 合計トークン数: {workflow_data['total_tokens']}")
+                    print(f"   - 合計ステップ数: {workflow_data['total_steps']}")
+                    print(f"   - 作成者ID: {workflow_data['created_by']['id']}")
+                    print(f"   - ユーザー: {workflow_data['created_by']['user']}")
+                    print(f"   - 作成時刻: {unix_to_datetime(workflow_data['created_at'])}")
+                    print(f"   - 終了時刻: {unix_to_datetime(workflow_data['finished_at'])}")
+                    print(f"   - 実行時間: 約{workflow_data['elapsed_time']:.2f}秒")
+                    print("\n2. 生成されたコンテンツ（詩）:")
+                    print(workflow_data['outputs']['response'])
+else:
+    print(f"エラー: ステータスコード {response.status_code}")
+    print(response.text)

requestDify.py

@@ -0,0 +1,2 @@
+requests==2.26.0
+python-dotenv==0.19.1