|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import os
|
|
from api.utils import get_base_config, decrypt_database_config
|
|
from api.utils.file_utils import get_project_base_directory
|
|
from api.utils.log_utils import LoggerFactory, getLogger
|
|
|
|
|
|
|
|
RAG_CONF_PATH = os.path.join(get_project_base_directory(), "conf")
|
|
SUBPROCESS_STD_LOG_NAME = "std.log"
|
|
|
|
ES = get_base_config("es", {})
|
|
MINIO = decrypt_database_config(name="minio")
|
|
try:
|
|
REDIS = decrypt_database_config(name="redis")
|
|
except Exception as e:
|
|
REDIS = {}
|
|
pass
|
|
DOC_MAXIMUM_SIZE = 128 * 1024 * 1024
|
|
|
|
|
|
LoggerFactory.set_directory(
|
|
os.path.join(
|
|
get_project_base_directory(),
|
|
"logs",
|
|
"rag"))
|
|
|
|
LoggerFactory.LEVEL = 30
|
|
|
|
es_logger = getLogger("es")
|
|
minio_logger = getLogger("minio")
|
|
cron_logger = getLogger("cron_logger")
|
|
cron_logger.setLevel(20)
|
|
chunk_logger = getLogger("chunk_logger")
|
|
database_logger = getLogger("database")
|
|
|
|
SVR_QUEUE_NAME = "rag_flow_svr_queue"
|
|
SVR_QUEUE_RETENTION = 60*60
|
|
SVR_QUEUE_MAX_LEN = 1024
|
|
SVR_CONSUMER_NAME = "rag_flow_svr_consumer"
|
|
SVR_CONSUMER_GROUP_NAME = "rag_flow_svr_consumer_group"
|
|
|