ArangoDB Integration

.github/workflows/docker/compose/chathistory-compose.yaml

@@ -7,3 +7,7 @@ services:
     build:
       dockerfile: comps/chathistory/mongo/Dockerfile
     image: ${REGISTRY:-opea}/chathistory-mongo-server:${TAG:-latest}
+  chathistory-arango-server:
+    build:
+      dockerfile: comps/chathistory/arango/Dockerfile
+    image: ${REGISTRY:-opea}/chathistory-arango-server:${TAG:-latest}

.github/workflows/docker/compose/dataprep-compose.yaml

@@ -63,3 +63,7 @@ services:
     build:
       dockerfile: comps/dataprep/multimedia2text/audio2text/Dockerfile
     image: ${REGISTRY:-opea}/dataprep-audio2text:${TAG:-latest}
+  dataprep-arango:
+    build:
+      dockerfile: comps/dataprep/arango/langchain/Dockerfile
+    image: ${REGISTRY:-opea}/dataprep-arango:${TAG:-latest}

.github/workflows/docker/compose/feedback_management-compose.yaml

@@ -7,3 +7,7 @@ services:
     build:
       dockerfile: comps/feedback_management/mongo/Dockerfile
     image: ${REGISTRY:-opea}/feedbackmanagement:${TAG:-latest}
+  feedbackmanagement-arango-server:
+    build:
+      dockerfile: comps/feedback_management/arango/Dockerfile
+    image: ${REGISTRY:-opea}/feedbackmanagement-arango-server:${TAG:-latest}

.github/workflows/docker/compose/prompt_registry-compose.yaml

@@ -7,3 +7,7 @@ services:
     build:
       dockerfile: comps/prompt_registry/mongo/Dockerfile
     image: ${REGISTRY:-opea}/promptregistry-mongo-server:${TAG:-latest}
+  promptregistry-arango-server:
+    build:
+      dockerfile: comps/prompt_registry/arango/Dockerfile
+    image: ${REGISTRY:-opea}/promptregistry-arango-server:${TAG:-latest}

.github/workflows/docker/compose/retrievers-compose.yaml

@@ -47,3 +47,7 @@ services:
     build:
       dockerfile: comps/retrievers/neo4j/llama_index/Dockerfile
     image: ${REGISTRY:-opea}/retriever-neo4j-llamaindex:${TAG:-latest}
+  retriever-arango:
+    build:
+      dockerfile: comps/retrievers/arango/langchain/Dockerfile
+    image: ${REGISTRY:-opea}/retriever-arango:${TAG:-latest}

.gitignore

@@ -1,3 +1,4 @@
 __pycache__
 *.egg-info/
 .DS_Store
+.venv

ARANGODB_README.md

@@ -0,0 +1,33 @@
+Instructions
+
+0. Create a virtual environment:
+
+```bash
+python -m venv .venv
+
+source .venv/bin/activate
+```
+
+1. Install the required packages:
+
+```bash
+pip install python-arango
+pip install langchain_openai
+pip install git+https://github.com/arangoml/langchain.git@arangodb#subdirectory=libs/community
+```
+
+2. Provision the ArangoDB with Vector Index image:
+
+```bash
+docker create --name arango-vector -p 8529:8529 -e ARANGO_ROOT_PASSWORD=test jbajic/arangodb-arm:vector-index-preview
+
+docker start arango-vector
+```
+
+3. Set your `OPENAI_API_KEY` environment variable (contact Anthony for access)
+
+4. Run the test script to confirm LangChain is working:
+
+```bash
+python langchain_test.py
+```

comps/chathistory/README.md

@@ -24,3 +24,7 @@ The Chat History microservice able to support various database backends for stor
 ### Chat History with MongoDB
 
 For more detail, please refer to this [README](./mongo/README.md)
+
+### Chat History with ArangoDB
+
+For more detail, please refer to this [README](./arango/README.md)

comps/chathistory/arango/Dockerfile

@@ -0,0 +1,30 @@
+# Copyright (C) 2024 Intel Corporation
+# SPDX-License-Identifier: Apache-2.0
+
+FROM python:3.11-slim
+
+ENV LANG=C.UTF-8
+
+RUN apt-get update -y && apt-get install -y --no-install-recommends --fix-missing \
+    build-essential \
+    libjemalloc-dev \
+    libgl1-mesa-glx
+
+RUN useradd -m -s /bin/bash user && \
+    mkdir -p /home/user && \
+    chown -R user /home/user/
+
+USER user
+
+COPY comps /home/user/comps
+COPY requirements.txt /home/user/
+
+RUN pip install --no-cache-dir --upgrade pip setuptools && \
+    pip install --no-cache-dir -r /home/user/comps/chathistory/arango/requirements.txt && \
+    pip install --no-cache-dir -r /home/user/requirements.txt
+
+ENV PYTHONPATH=$PYTHONPATH:/home/user
+
+WORKDIR /home/user/comps/chathistory/arango
+
+ENTRYPOINT ["python", "chat.py"]

comps/chathistory/arango/README.md

@@ -0,0 +1,119 @@
+# 📝 Chat History Microservice with ArangoDB
+
+This README provides setup guides and all the necessary information about the Chat History microservice with ArangoDB database.
+
+---
+
+## Setup Environment Variables
+
+See `config.py` for default values.
+
+```bash
+export ARANGO_URL=${ARANGO_URL}
+export ARANGO_USERNAME=${ARANGO_USERNAME}
+export ARANGO_PASSWORD=${ARANGO_PASSWORD}
+export ARANGO_DB_NAME=${ARANGO_DB_NAME}
+export ARANGO_COLLECTION_NAME=${ARANGO_COLLECTION_NAME}
+```
+
+---
+
+## 🚀Start Microservice with Docker
+
+### Build Docker Image
+
+```bash
+cd ../../../../
+docker build -t opea/chathistory-arango-server:latest --build-arg https_proxy=$https_proxy --build-arg http_proxy=$http_proxy -f comps/chathistory/arango/Dockerfile .
+```
+
+### Run Docker with CLI
+
+- Run ArangoDB image container
+
+  ```bash
+  docker run -d -p 8529:8529 --name=arango arangodb/arangodb:latest
+  ```
+
+- Run the Chat History microservice
+
+  ```bash
+  docker run -p 6012:6012 \  
+  -e http_proxy=$http_proxy \
+  -e https_proxy=$https_proxy \
+  -e no_proxy=$no_proxy \
+  -e ARANGO_URL=${ARANGO_URL} \
+  -e ARANGO_USERNAME=${ARANGO_USERNAME} \
+  -e ARANGO_PASSWORD=${ARANGO_PASSWORD} \
+  -e ARANGO_DB_NAME=${ARANGO_DB_NAME} \
+  -e ARANGO_COLLECTION_NAME=${ARANGO_COLLECTION_NAME} \
+  opea/chathistory-arango-server:latest
+  ```
+
+---
+
+## ✅ Invoke Microservice
+
+The Chat History microservice exposes the following API endpoints:
+
+- Create new chat conversation
+
+  ```bash
+  curl -X 'POST' \
+    http://${host_ip}:6012/v1/chathistory/create \
+    -H 'accept: application/json' \
+    -H 'Content-Type: application/json' \
+    -d '{
+    "data": {
+      "messages": "test Messages", "user": "test"
+    }
+  }'
+  ```
+
+- Get all the Conversations for a user
+
+  ```bash
+  curl -X 'POST' \
+    http://${host_ip}:6012/v1/chathistory/get \
+    -H 'accept: application/json' \
+    -H 'Content-Type: application/json' \
+    -d '{
+    "user": "test"}'
+  ```
+
+- Get a specific conversation by id.
+
+  ```bash
+  curl -X 'POST' \
+    http://${host_ip}:6012/v1/chathistory/get \
+    -H 'accept: application/json' \
+    -H 'Content-Type: application/json' \
+    -d '{
+    "user": "test", "id":"48918"}'
+  ```
+
+- Update the conversation by id.
+
+  ```bash
+  curl -X 'POST' \
+    http://${host_ip}:6012/v1/chathistory/create \
+    -H 'accept: application/json' \
+    -H 'Content-Type: application/json' \
+    -d '{
+    "data": {
+      "messages": "test Messages Update", "user": "test"
+    },
+    "id":"48918"
+  }'
+  ```
+
+- Delete a stored conversation.
+
+  ```bash
+  curl -X 'POST' \
+    http://${host_ip}:6012/v1/chathistory/delete \
+    -H 'accept: application/json' \
+    -H 'Content-Type: application/json' \
+    -d '{
+    "user": "test", "id":"48918"}'
+  ```

comps/chathistory/arango/arango_conn.py

@@ -0,0 +1,32 @@
+# Copyright (C) 2024 Intel Corporation
+# SPDX-License-Identifier: Apache-2.0
+
+from arango import ArangoClient as PythonArangoClient
+from arango.database import StandardDatabase
+from config import ARANGO_URL, ARANGO_PASSWORD, ARANGO_USERNAME, ARANGO_DB_NAME
+
+
+class ArangoClient:
+    conn_url = ARANGO_URL
+
+    @staticmethod
+    def get_db_client() -> StandardDatabase:
+        try:
+            # Create client
+            client = PythonArangoClient(hosts=ArangoClient.conn_url)
+
+            # First connect to _system database
+            sys_db = client.db("_system", username=ARANGO_USERNAME, password=ARANGO_PASSWORD, verify=True)
+
+            # Create target database if it doesn't exist
+            if not sys_db.has_database(ARANGO_DB_NAME):
+                sys_db.create_database(ARANGO_DB_NAME)
+
+            # Now connect to the target database
+            db = client.db(ARANGO_DB_NAME, username=ARANGO_USERNAME, password=ARANGO_PASSWORD, verify=True)
+
+            return db
+
+        except Exception as e:
+            print(e)
+            raise e