Upload 3 files

app.py

@@ -0,0 +1,203 @@
+import gradio as gr
+import random
+import time
+import csv
+import os
+import pandas as pd
+from openai import OpenAI
+import numpy as np
+import ast
+import json
+
+
+# ユーザーの諸々の情報やプロンプトを受け取り返答する
+def search_teacher(job_type, job_start_dates, tool_function_arguments):
+    time.sleep(1)
+
+    user_request = ', '.join(list(tool_function_arguments.values())[:-2])
+    user_message_embedded_vector = \
+        client.embeddings.create(input=[user_request.replace("\n", " ")], model='text-embedding-3-small').data[
+            0].embedding
+
+    data = pd.read_csv(os.environ['DATA_PATH'])
+
+    # job_type の日本語を英語に変換
+    if job_type == '常勤':
+        job_type = 'full time'
+    elif job_type == '非常勤':
+        job_type = 'part time'
+
+    # job_start_dates の日本語を英語に変換
+    job_start_date_translation = {
+        '今年度': 'This Year',
+        '来年度': 'Next Year',
+        '来来年度': 'Year After Next'
+    }
+    # job_start_dates が文字列の場合リストに変換(単一選択の場合を考慮)
+    if isinstance(job_start_dates, str):
+        job_start_dates = [job_start_dates]
+    # 英語に変換
+    job_start_dates = [job_start_date_translation.get(date, date) for date in job_start_dates]
+
+    # job_type と job_start_dates でフィルタリング
+    filtered_data = data[(data['job_type'] == job_type) & (data['job_start_date'].isin(job_start_dates))].copy()
+
+    result = []
+
+    for index, row in filtered_data.iterrows():
+        teacher_embedded_vector = ast.literal_eval(row['embedding'])
+
+        similarity = np.dot(user_message_embedded_vector, teacher_embedded_vector) / (
+                np.linalg.norm(user_message_embedded_vector) * np.linalg.norm(teacher_embedded_vector))
+
+        if len(result) < 3:
+            result.append((index, similarity))
+            result.sort(key=lambda x: x[1], reverse=True)
+        else:
+            if similarity > result[-1][1]:
+                result[-1] = (index, similarity)
+                result.sort(key=lambda x: x[1], reverse=True)
+
+    formatted_result = []
+    for index, similarity in result:
+        name = filtered_data.loc[index, 'name']
+        temp = f"{name}: {similarity}"
+        formatted_result.append(temp)
+
+    return ', '.join(formatted_result)
+
+
+def openai_api(job_type, job_start_dates, history):
+    # GPTにユーザーの入力を送信
+    message = client.beta.threads.messages.create(
+        thread_id=thread.id,
+        role="user",
+        content=history[-1][0]
+    )
+
+    # 送信した入力を実行
+    run = client.beta.threads.runs.create(
+        thread_id=thread.id,
+        assistant_id=assistant.id,
+    )
+
+    while True:
+        run = client.beta.threads.runs.retrieve(
+            thread_id=thread.id,
+            run_id=run.id
+        )
+        if run.status == 'completed':
+            break
+        elif run.status == 'requires_action':
+            tool_id = run.required_action.submit_tool_outputs.tool_calls[0].id
+            tool_function_arguments = json.loads(
+                run.required_action.submit_tool_outputs.tool_calls[0].function.arguments)
+
+            tool_function_output = search_teacher(job_type, job_start_dates, tool_function_arguments)
+
+            run = client.beta.threads.runs.submit_tool_outputs(
+                thread_id=thread.id,
+                run_id=run.id,
+                tool_outputs=[
+                    {
+                        "tool_call_id": tool_id,
+                        "output": tool_function_output,
+                    }
+                ]
+            )
+            time.sleep(3)
+
+        time.sleep(0.5)
+
+    messages = client.beta.threads.messages.list(
+        thread_id=thread.id,
+        order="asc"
+    )
+
+    return messages.data[-1].content[0].text.value
+
+
+def user(user_job_type, user_job_start_date, user_message, history):
+    gr.Info(str(user_job_type))
+    gr.Info(str(user_job_start_date))
+
+    return None, history + [[user_message, None]]
+
+
+def bot(job_type, job_start_date, history):
+    prompt = ""
+    # apiを叩くためにデータを加工するなりする
+    for chat in history[:-1]:
+        prompt += '"' + chat[0] + '", "' + chat[1] + '"'
+
+    bot_message = openai_api(job_type, job_start_date, history)
+
+    history[-1][1] = ""
+    for character in bot_message:
+        history[-1][1] += character
+        time.sleep(0.01)
+
+        yield history
+
+
+with gr.Blocks(theme=gr.themes.Soft()) as demo:
+    global assistant
+    global thread
+    global client
+
+    client = OpenAI(max_retries=5)
+
+    assistant = client.beta.assistants.create(
+        name='connpath_demo',
+        instructions=os.environ['INSTRUCTIONS'],
+        model="gpt-4-0125-preview",
+        tools=[{
+            "type": "function",
+            "function": {
+                "name": "connpath_demo_gpt",
+                "description": "検索を支援する",
+                "parameters": {
+                    "type": "object",
+                    "properties": {
+                        "educational_goals": {"type": "string", "description": "教育の目的"},
+                        "student_profile": {"type": "string", "description": "対象のプロフィール"},
+                        "required_skills_experience": {"type": "string", "description": "求められるスキル"},
+                        "teaching_method_environment": {"type": "string", "description": "教育する環境"},
+                        "evaluation_feedback": {"type": "string", "description": "教育の評価方法"}
+                    },
+                    "required": ["educational_goals", "student_profile", "required_skills_experience",
+                                 "teaching_method_environment", "evaluation_feedback"]
+                }
+            }
+        }]
+    )
+
+    thread = client.beta.threads.create()
+
+    # これがhistoryを保持
+    chatbot = gr.Chatbot(show_copy_button=True)
+
+    # これがuser_job_typeを保持 (str型)
+    job_type = gr.Radio(["常勤", "非常勤"],
+                        label="Job Type",
+                        info="探している雇用形態について")
+
+    # これがuser_job_start_dateを保持 (list型)
+    job_start_date = gr.CheckboxGroup(["今年度", "来年度", "来来年度"],
+                                      label="Start Date",
+                                      info="探している就業時期について")
+
+    # これがuser_messageを保持
+    msg = gr.Textbox(label="input message")
+    clear = gr.Button("clear history")
+
+    msg.submit(user,
+               [job_type, job_start_date, msg, chatbot],
+               [msg, chatbot],
+               queue=True
+               ).then(bot, [job_type, job_start_date, chatbot], chatbot)
+    clear.click(lambda: None, None, chatbot, queue=False)
+
+if __name__ == "__main__":
+    demo.queue()
+    demo.launch(auth=(os.environ['USER_NAME'], os.environ['PASSWORD']))

requirements.txt

@@ -0,0 +1,158 @@
+aiofiles==23.2.1
+aiohttp==3.9.3
+aiosignal==1.3.1
+altair==5.2.0
+annotated-types==0.6.0
+anyio==3.7.1
+argon2-cffi==23.1.0
+argon2-cffi-bindings==21.2.0
+arrow==1.2.3
+asttokens==2.2.1
+async-lru==2.0.4
+async-timeout==4.0.3
+attrs==23.1.0
+Babel==2.12.1
+backcall==0.2.0
+beautifulsoup4==4.12.2
+bleach==6.0.0
+certifi==2023.7.22
+cffi==1.15.1
+charset-normalizer==3.2.0
+click==8.1.7
+colorama==0.4.6
+comm==0.1.4
+contourpy==1.1.0
+cycler==0.11.0
+dataclasses-json==0.6.4
+debugpy==1.6.7.post1
+decorator==5.1.1
+defusedxml==0.7.1
+distro==1.9.0
+et-xmlfile==1.1.0
+exceptiongroup==1.1.3
+executing==1.2.0
+fastapi==0.109.2
+fastjsonschema==2.18.0
+ffmpy==0.3.2
+filelock==3.13.1
+fonttools==4.42.0
+fqdn==1.5.1
+frozenlist==1.4.1
+fsspec==2024.2.0
+gradio==4.19.2
+gradio_client==0.10.1
+greenlet==3.0.3
+h11==0.14.0
+httpcore==1.0.4
+httpx==0.27.0
+huggingface-hub==0.20.3
+idna==3.4
+importlib-metadata==6.8.0
+importlib-resources==6.0.1
+ipykernel==6.25.1
+ipython==8.14.0
+isoduration==20.11.0
+jedi==0.19.0
+Jinja2==3.1.2
+json5==0.9.14
+jsonpatch==1.33
+jsonpointer==2.4
+jsonschema==4.19.0
+jsonschema-specifications==2023.7.1
+jupyter-events==0.7.0
+jupyter-lsp==2.2.0
+jupyter_client==8.3.0
+jupyter_core==5.3.1
+jupyter_server==2.7.1
+jupyter_server_terminals==0.4.4
+jupyterlab==4.0.5
+jupyterlab-pygments==0.2.2
+jupyterlab_server==2.24.0
+kiwisolver==1.4.4
+langchain==0.1.9
+langchain-community==0.0.24
+langchain-core==0.1.26
+langsmith==0.1.7
+markdown-it-py==3.0.0
+MarkupSafe==2.1.3
+marshmallow==3.20.2
+matplotlib==3.7.2
+matplotlib-inline==0.1.6
+mdurl==0.1.2
+mistune==3.0.1
+multidict==6.0.5
+mypy-extensions==1.0.0
+nbclient==0.8.0
+nbconvert==7.7.3
+nbformat==5.9.2
+nest-asyncio==1.5.7
+notebook_shim==0.2.3
+numpy==1.25.2
+openai==1.12.0
+openpyxl==3.1.2
+orjson==3.9.15
+overrides==7.4.0
+packaging==23.2
+pandas==2.0.3
+pandocfilters==1.5.0
+parso==0.8.3
+pexpect==4.8.0
+pickleshare==0.7.5
+Pillow==10.0.0
+platformdirs==3.10.0
+prometheus-client==0.17.1
+prompt-toolkit==3.0.39
+psutil==5.9.5
+ptyprocess==0.7.0
+pure-eval==0.2.2
+pycparser==2.21
+pydantic==2.6.2
+pydantic_core==2.16.3
+pydub==0.25.1
+Pygments==2.16.1
+pyparsing==3.0.9
+python-dateutil==2.8.2
+python-json-logger==2.0.7
+python-multipart==0.0.9
+pytz==2023.3
+PyYAML==6.0.1
+pyzmq==25.1.1
+referencing==0.30.2
+requests==2.31.0
+rfc3339-validator==0.1.4
+rfc3986-validator==0.1.1
+rich==13.7.0
+rpds-py==0.9.2
+ruff==0.2.2
+semantic-version==2.10.0
+Send2Trash==1.8.2
+shellingham==1.5.4
+six==1.16.0
+sniffio==1.3.0
+soupsieve==2.4.1
+SQLAlchemy==2.0.27
+stack-data==0.6.2
+starlette==0.36.3
+tenacity==8.2.3
+terminado==0.17.1
+tinycss2==1.2.1
+tomli==2.0.1
+tomlkit==0.12.0
+toolz==0.12.1
+tornado==6.3.3
+tqdm==4.66.2
+traitlets==5.9.0
+typer==0.9.0
+typing-inspect==0.9.0
+typing_extensions==4.9.0
+tzdata==2023.3
+uri-template==1.3.0
+urllib3==2.0.4
+uvicorn==0.27.1
+wcwidth==0.2.6
+webcolors==1.13
+webencodings==0.5.1
+websocket-client==1.6.1
+websockets==11.0.3
+yarl==1.9.4
+zipp==3.16.2