|
|
|
|
|
|
|
|
import opendal |
|
|
import opendal |
|
|
import logging |
|
|
import logging |
|
|
import pymysql |
|
|
import pymysql |
|
|
|
|
|
from urllib.parse import quote_plus |
|
|
|
|
|
|
|
|
from api.utils import get_base_config |
|
|
from api.utils import get_base_config |
|
|
from rag.utils import singleton |
|
|
from rag.utils import singleton |
|
|
|
|
|
|
|
|
"table": opendal_config.get("config").get("oss_table", "opendal_storage"), |
|
|
"table": opendal_config.get("config").get("oss_table", "opendal_storage"), |
|
|
"max_allowed_packet": str(max_packet) |
|
|
"max_allowed_packet": str(max_packet) |
|
|
} |
|
|
} |
|
|
kwargs["connection_string"] = f"mysql://{kwargs['user']}:{kwargs['password']}@{kwargs['host']}:{kwargs['port']}/{kwargs['database']}?max_allowed_packet={max_packet}" |
|
|
|
|
|
|
|
|
kwargs["connection_string"] = f"mysql://{kwargs['user']}:{quote_plus(kwargs['password'])}@{kwargs['host']}:{kwargs['port']}/{kwargs['database']}?max_allowed_packet={max_packet}" |
|
|
else: |
|
|
else: |
|
|
scheme = opendal_config.get("scheme") |
|
|
scheme = opendal_config.get("scheme") |
|
|
config_data = opendal_config.get("config", {}) |
|
|
config_data = opendal_config.get("config", {}) |