dataset.py 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689
  1. import base64
  2. import enum
  3. import hashlib
  4. import hmac
  5. import json
  6. import logging
  7. import os
  8. import pickle
  9. import re
  10. import time
  11. from json import JSONDecodeError
  12. from sqlalchemy import func
  13. from sqlalchemy.dialects.postgresql import JSONB
  14. from configs import dify_config
  15. from core.rag.retrieval.retrieval_methods import RetrievalMethod
  16. from extensions.ext_database import db
  17. from extensions.ext_storage import storage
  18. from .account import Account
  19. from .model import App, Tag, TagBinding, UploadFile
  20. from .types import StringUUID
  21. class DatasetPermissionEnum(str, enum.Enum):
  22. ONLY_ME = "only_me"
  23. ALL_TEAM = "all_team_members"
  24. PARTIAL_TEAM = "partial_members"
  25. class Dataset(db.Model):
  26. __tablename__ = "datasets"
  27. __table_args__ = (
  28. db.PrimaryKeyConstraint("id", name="dataset_pkey"),
  29. db.Index("dataset_tenant_idx", "tenant_id"),
  30. db.Index("retrieval_model_idx", "retrieval_model", postgresql_using="gin"),
  31. )
  32. INDEXING_TECHNIQUE_LIST = ["high_quality", "economy", None]
  33. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  34. tenant_id = db.Column(StringUUID, nullable=False)
  35. name = db.Column(db.String(255), nullable=False)
  36. description = db.Column(db.Text, nullable=True)
  37. provider = db.Column(db.String(255), nullable=False, server_default=db.text("'vendor'::character varying"))
  38. permission = db.Column(db.String(255), nullable=False, server_default=db.text("'only_me'::character varying"))
  39. data_source_type = db.Column(db.String(255))
  40. indexing_technique = db.Column(db.String(255), nullable=True)
  41. index_struct = db.Column(db.Text, nullable=True)
  42. created_by = db.Column(StringUUID, nullable=False)
  43. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  44. updated_by = db.Column(StringUUID, nullable=True)
  45. updated_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  46. embedding_model = db.Column(db.String(255), nullable=True)
  47. embedding_model_provider = db.Column(db.String(255), nullable=True)
  48. collection_binding_id = db.Column(StringUUID, nullable=True)
  49. retrieval_model = db.Column(JSONB, nullable=True)
  50. @property
  51. def dataset_keyword_table(self):
  52. dataset_keyword_table = (
  53. db.session.query(DatasetKeywordTable).filter(DatasetKeywordTable.dataset_id == self.id).first()
  54. )
  55. if dataset_keyword_table:
  56. return dataset_keyword_table
  57. return None
  58. @property
  59. def index_struct_dict(self):
  60. return json.loads(self.index_struct) if self.index_struct else None
  61. @property
  62. def created_by_account(self):
  63. return db.session.get(Account, self.created_by)
  64. @property
  65. def latest_process_rule(self):
  66. return (
  67. DatasetProcessRule.query.filter(DatasetProcessRule.dataset_id == self.id)
  68. .order_by(DatasetProcessRule.created_at.desc())
  69. .first()
  70. )
  71. @property
  72. def app_count(self):
  73. return (
  74. db.session.query(func.count(AppDatasetJoin.id))
  75. .filter(AppDatasetJoin.dataset_id == self.id, App.id == AppDatasetJoin.app_id)
  76. .scalar()
  77. )
  78. @property
  79. def document_count(self):
  80. return db.session.query(func.count(Document.id)).filter(Document.dataset_id == self.id).scalar()
  81. @property
  82. def available_document_count(self):
  83. return (
  84. db.session.query(func.count(Document.id))
  85. .filter(
  86. Document.dataset_id == self.id,
  87. Document.indexing_status == "completed",
  88. Document.enabled == True,
  89. Document.archived == False,
  90. )
  91. .scalar()
  92. )
  93. @property
  94. def available_segment_count(self):
  95. return (
  96. db.session.query(func.count(DocumentSegment.id))
  97. .filter(
  98. DocumentSegment.dataset_id == self.id,
  99. DocumentSegment.status == "completed",
  100. DocumentSegment.enabled == True,
  101. )
  102. .scalar()
  103. )
  104. @property
  105. def word_count(self):
  106. return (
  107. Document.query.with_entities(func.coalesce(func.sum(Document.word_count)))
  108. .filter(Document.dataset_id == self.id)
  109. .scalar()
  110. )
  111. @property
  112. def doc_form(self):
  113. document = db.session.query(Document).filter(Document.dataset_id == self.id).first()
  114. if document:
  115. return document.doc_form
  116. return None
  117. @property
  118. def retrieval_model_dict(self):
  119. default_retrieval_model = {
  120. "search_method": RetrievalMethod.SEMANTIC_SEARCH.value,
  121. "reranking_enable": False,
  122. "reranking_model": {"reranking_provider_name": "", "reranking_model_name": ""},
  123. "top_k": 2,
  124. "score_threshold_enabled": False,
  125. }
  126. return self.retrieval_model or default_retrieval_model
  127. @property
  128. def tags(self):
  129. tags = (
  130. db.session.query(Tag)
  131. .join(TagBinding, Tag.id == TagBinding.tag_id)
  132. .filter(
  133. TagBinding.target_id == self.id,
  134. TagBinding.tenant_id == self.tenant_id,
  135. Tag.tenant_id == self.tenant_id,
  136. Tag.type == "knowledge",
  137. )
  138. .all()
  139. )
  140. return tags or []
  141. @staticmethod
  142. def gen_collection_name_by_id(dataset_id: str) -> str:
  143. normalized_dataset_id = dataset_id.replace("-", "_")
  144. return f"Vector_index_{normalized_dataset_id}_Node"
  145. class DatasetProcessRule(db.Model):
  146. __tablename__ = "dataset_process_rules"
  147. __table_args__ = (
  148. db.PrimaryKeyConstraint("id", name="dataset_process_rule_pkey"),
  149. db.Index("dataset_process_rule_dataset_id_idx", "dataset_id"),
  150. )
  151. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  152. dataset_id = db.Column(StringUUID, nullable=False)
  153. mode = db.Column(db.String(255), nullable=False, server_default=db.text("'automatic'::character varying"))
  154. rules = db.Column(db.Text, nullable=True)
  155. created_by = db.Column(StringUUID, nullable=False)
  156. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  157. MODES = ["automatic", "custom"]
  158. PRE_PROCESSING_RULES = ["remove_stopwords", "remove_extra_spaces", "remove_urls_emails"]
  159. AUTOMATIC_RULES = {
  160. "pre_processing_rules": [
  161. {"id": "remove_extra_spaces", "enabled": True},
  162. {"id": "remove_urls_emails", "enabled": False},
  163. ],
  164. "segmentation": {"delimiter": "\n", "max_tokens": 500, "chunk_overlap": 50},
  165. }
  166. def to_dict(self):
  167. return {
  168. "id": self.id,
  169. "dataset_id": self.dataset_id,
  170. "mode": self.mode,
  171. "rules": self.rules_dict,
  172. "created_by": self.created_by,
  173. "created_at": self.created_at,
  174. }
  175. @property
  176. def rules_dict(self):
  177. try:
  178. return json.loads(self.rules) if self.rules else None
  179. except JSONDecodeError:
  180. return None
  181. class Document(db.Model):
  182. __tablename__ = "documents"
  183. __table_args__ = (
  184. db.PrimaryKeyConstraint("id", name="document_pkey"),
  185. db.Index("document_dataset_id_idx", "dataset_id"),
  186. db.Index("document_is_paused_idx", "is_paused"),
  187. db.Index("document_tenant_idx", "tenant_id"),
  188. )
  189. # initial fields
  190. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  191. tenant_id = db.Column(StringUUID, nullable=False)
  192. dataset_id = db.Column(StringUUID, nullable=False)
  193. position = db.Column(db.Integer, nullable=False)
  194. data_source_type = db.Column(db.String(255), nullable=False)
  195. data_source_info = db.Column(db.Text, nullable=True)
  196. dataset_process_rule_id = db.Column(StringUUID, nullable=True)
  197. batch = db.Column(db.String(255), nullable=False)
  198. name = db.Column(db.String(255), nullable=False)
  199. created_from = db.Column(db.String(255), nullable=False)
  200. created_by = db.Column(StringUUID, nullable=False)
  201. created_api_request_id = db.Column(StringUUID, nullable=True)
  202. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  203. # start processing
  204. processing_started_at = db.Column(db.DateTime, nullable=True)
  205. # parsing
  206. file_id = db.Column(db.Text, nullable=True)
  207. word_count = db.Column(db.Integer, nullable=True)
  208. parsing_completed_at = db.Column(db.DateTime, nullable=True)
  209. # cleaning
  210. cleaning_completed_at = db.Column(db.DateTime, nullable=True)
  211. # split
  212. splitting_completed_at = db.Column(db.DateTime, nullable=True)
  213. # indexing
  214. tokens = db.Column(db.Integer, nullable=True)
  215. indexing_latency = db.Column(db.Float, nullable=True)
  216. completed_at = db.Column(db.DateTime, nullable=True)
  217. # pause
  218. is_paused = db.Column(db.Boolean, nullable=True, server_default=db.text("false"))
  219. paused_by = db.Column(StringUUID, nullable=True)
  220. paused_at = db.Column(db.DateTime, nullable=True)
  221. # error
  222. error = db.Column(db.Text, nullable=True)
  223. stopped_at = db.Column(db.DateTime, nullable=True)
  224. # basic fields
  225. indexing_status = db.Column(db.String(255), nullable=False, server_default=db.text("'waiting'::character varying"))
  226. enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  227. disabled_at = db.Column(db.DateTime, nullable=True)
  228. disabled_by = db.Column(StringUUID, nullable=True)
  229. archived = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  230. archived_reason = db.Column(db.String(255), nullable=True)
  231. archived_by = db.Column(StringUUID, nullable=True)
  232. archived_at = db.Column(db.DateTime, nullable=True)
  233. updated_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  234. doc_type = db.Column(db.String(40), nullable=True)
  235. doc_metadata = db.Column(db.JSON, nullable=True)
  236. doc_form = db.Column(db.String(255), nullable=False, server_default=db.text("'text_model'::character varying"))
  237. doc_language = db.Column(db.String(255), nullable=True)
  238. DATA_SOURCES = ["upload_file", "notion_import", "website_crawl"]
  239. @property
  240. def display_status(self):
  241. status = None
  242. if self.indexing_status == "waiting":
  243. status = "queuing"
  244. elif self.indexing_status not in {"completed", "error", "waiting"} and self.is_paused:
  245. status = "paused"
  246. elif self.indexing_status in {"parsing", "cleaning", "splitting", "indexing"}:
  247. status = "indexing"
  248. elif self.indexing_status == "error":
  249. status = "error"
  250. elif self.indexing_status == "completed" and not self.archived and self.enabled:
  251. status = "available"
  252. elif self.indexing_status == "completed" and not self.archived and not self.enabled:
  253. status = "disabled"
  254. elif self.indexing_status == "completed" and self.archived:
  255. status = "archived"
  256. return status
  257. @property
  258. def data_source_info_dict(self):
  259. if self.data_source_info:
  260. try:
  261. data_source_info_dict = json.loads(self.data_source_info)
  262. except JSONDecodeError:
  263. data_source_info_dict = {}
  264. return data_source_info_dict
  265. return None
  266. @property
  267. def data_source_detail_dict(self):
  268. if self.data_source_info:
  269. if self.data_source_type == "upload_file":
  270. data_source_info_dict = json.loads(self.data_source_info)
  271. file_detail = (
  272. db.session.query(UploadFile)
  273. .filter(UploadFile.id == data_source_info_dict["upload_file_id"])
  274. .one_or_none()
  275. )
  276. if file_detail:
  277. return {
  278. "upload_file": {
  279. "id": file_detail.id,
  280. "name": file_detail.name,
  281. "size": file_detail.size,
  282. "extension": file_detail.extension,
  283. "mime_type": file_detail.mime_type,
  284. "created_by": file_detail.created_by,
  285. "created_at": file_detail.created_at.timestamp(),
  286. }
  287. }
  288. elif self.data_source_type in {"notion_import", "website_crawl"}:
  289. return json.loads(self.data_source_info)
  290. return {}
  291. @property
  292. def average_segment_length(self):
  293. if self.word_count and self.word_count != 0 and self.segment_count and self.segment_count != 0:
  294. return self.word_count // self.segment_count
  295. return 0
  296. @property
  297. def dataset_process_rule(self):
  298. if self.dataset_process_rule_id:
  299. return db.session.get(DatasetProcessRule, self.dataset_process_rule_id)
  300. return None
  301. @property
  302. def dataset(self):
  303. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).one_or_none()
  304. @property
  305. def segment_count(self):
  306. return DocumentSegment.query.filter(DocumentSegment.document_id == self.id).count()
  307. @property
  308. def hit_count(self):
  309. return (
  310. DocumentSegment.query.with_entities(func.coalesce(func.sum(DocumentSegment.hit_count)))
  311. .filter(DocumentSegment.document_id == self.id)
  312. .scalar()
  313. )
  314. def to_dict(self):
  315. return {
  316. "id": self.id,
  317. "tenant_id": self.tenant_id,
  318. "dataset_id": self.dataset_id,
  319. "position": self.position,
  320. "data_source_type": self.data_source_type,
  321. "data_source_info": self.data_source_info,
  322. "dataset_process_rule_id": self.dataset_process_rule_id,
  323. "batch": self.batch,
  324. "name": self.name,
  325. "created_from": self.created_from,
  326. "created_by": self.created_by,
  327. "created_api_request_id": self.created_api_request_id,
  328. "created_at": self.created_at,
  329. "processing_started_at": self.processing_started_at,
  330. "file_id": self.file_id,
  331. "word_count": self.word_count,
  332. "parsing_completed_at": self.parsing_completed_at,
  333. "cleaning_completed_at": self.cleaning_completed_at,
  334. "splitting_completed_at": self.splitting_completed_at,
  335. "tokens": self.tokens,
  336. "indexing_latency": self.indexing_latency,
  337. "completed_at": self.completed_at,
  338. "is_paused": self.is_paused,
  339. "paused_by": self.paused_by,
  340. "paused_at": self.paused_at,
  341. "error": self.error,
  342. "stopped_at": self.stopped_at,
  343. "indexing_status": self.indexing_status,
  344. "enabled": self.enabled,
  345. "disabled_at": self.disabled_at,
  346. "disabled_by": self.disabled_by,
  347. "archived": self.archived,
  348. "archived_reason": self.archived_reason,
  349. "archived_by": self.archived_by,
  350. "archived_at": self.archived_at,
  351. "updated_at": self.updated_at,
  352. "doc_type": self.doc_type,
  353. "doc_metadata": self.doc_metadata,
  354. "doc_form": self.doc_form,
  355. "doc_language": self.doc_language,
  356. "display_status": self.display_status,
  357. "data_source_info_dict": self.data_source_info_dict,
  358. "average_segment_length": self.average_segment_length,
  359. "dataset_process_rule": self.dataset_process_rule.to_dict() if self.dataset_process_rule else None,
  360. "dataset": self.dataset.to_dict() if self.dataset else None,
  361. "segment_count": self.segment_count,
  362. "hit_count": self.hit_count,
  363. }
  364. @classmethod
  365. def from_dict(cls, data: dict):
  366. return cls(
  367. id=data.get("id"),
  368. tenant_id=data.get("tenant_id"),
  369. dataset_id=data.get("dataset_id"),
  370. position=data.get("position"),
  371. data_source_type=data.get("data_source_type"),
  372. data_source_info=data.get("data_source_info"),
  373. dataset_process_rule_id=data.get("dataset_process_rule_id"),
  374. batch=data.get("batch"),
  375. name=data.get("name"),
  376. created_from=data.get("created_from"),
  377. created_by=data.get("created_by"),
  378. created_api_request_id=data.get("created_api_request_id"),
  379. created_at=data.get("created_at"),
  380. processing_started_at=data.get("processing_started_at"),
  381. file_id=data.get("file_id"),
  382. word_count=data.get("word_count"),
  383. parsing_completed_at=data.get("parsing_completed_at"),
  384. cleaning_completed_at=data.get("cleaning_completed_at"),
  385. splitting_completed_at=data.get("splitting_completed_at"),
  386. tokens=data.get("tokens"),
  387. indexing_latency=data.get("indexing_latency"),
  388. completed_at=data.get("completed_at"),
  389. is_paused=data.get("is_paused"),
  390. paused_by=data.get("paused_by"),
  391. paused_at=data.get("paused_at"),
  392. error=data.get("error"),
  393. stopped_at=data.get("stopped_at"),
  394. indexing_status=data.get("indexing_status"),
  395. enabled=data.get("enabled"),
  396. disabled_at=data.get("disabled_at"),
  397. disabled_by=data.get("disabled_by"),
  398. archived=data.get("archived"),
  399. archived_reason=data.get("archived_reason"),
  400. archived_by=data.get("archived_by"),
  401. archived_at=data.get("archived_at"),
  402. updated_at=data.get("updated_at"),
  403. doc_type=data.get("doc_type"),
  404. doc_metadata=data.get("doc_metadata"),
  405. doc_form=data.get("doc_form"),
  406. doc_language=data.get("doc_language"),
  407. )
  408. class DocumentSegment(db.Model):
  409. __tablename__ = "document_segments"
  410. __table_args__ = (
  411. db.PrimaryKeyConstraint("id", name="document_segment_pkey"),
  412. db.Index("document_segment_dataset_id_idx", "dataset_id"),
  413. db.Index("document_segment_document_id_idx", "document_id"),
  414. db.Index("document_segment_tenant_dataset_idx", "dataset_id", "tenant_id"),
  415. db.Index("document_segment_tenant_document_idx", "document_id", "tenant_id"),
  416. db.Index("document_segment_dataset_node_idx", "dataset_id", "index_node_id"),
  417. db.Index("document_segment_tenant_idx", "tenant_id"),
  418. )
  419. # initial fields
  420. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  421. tenant_id = db.Column(StringUUID, nullable=False)
  422. dataset_id = db.Column(StringUUID, nullable=False)
  423. document_id = db.Column(StringUUID, nullable=False)
  424. position = db.Column(db.Integer, nullable=False)
  425. content = db.Column(db.Text, nullable=False)
  426. answer = db.Column(db.Text, nullable=True)
  427. word_count = db.Column(db.Integer, nullable=False)
  428. tokens = db.Column(db.Integer, nullable=False)
  429. # indexing fields
  430. keywords = db.Column(db.JSON, nullable=True)
  431. index_node_id = db.Column(db.String(255), nullable=True)
  432. index_node_hash = db.Column(db.String(255), nullable=True)
  433. # basic fields
  434. hit_count = db.Column(db.Integer, nullable=False, default=0)
  435. enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  436. disabled_at = db.Column(db.DateTime, nullable=True)
  437. disabled_by = db.Column(StringUUID, nullable=True)
  438. status = db.Column(db.String(255), nullable=False, server_default=db.text("'waiting'::character varying"))
  439. created_by = db.Column(StringUUID, nullable=False)
  440. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  441. updated_by = db.Column(StringUUID, nullable=True)
  442. updated_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  443. indexing_at = db.Column(db.DateTime, nullable=True)
  444. completed_at = db.Column(db.DateTime, nullable=True)
  445. error = db.Column(db.Text, nullable=True)
  446. stopped_at = db.Column(db.DateTime, nullable=True)
  447. @property
  448. def dataset(self):
  449. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).first()
  450. @property
  451. def document(self):
  452. return db.session.query(Document).filter(Document.id == self.document_id).first()
  453. @property
  454. def previous_segment(self):
  455. return (
  456. db.session.query(DocumentSegment)
  457. .filter(DocumentSegment.document_id == self.document_id, DocumentSegment.position == self.position - 1)
  458. .first()
  459. )
  460. @property
  461. def next_segment(self):
  462. return (
  463. db.session.query(DocumentSegment)
  464. .filter(DocumentSegment.document_id == self.document_id, DocumentSegment.position == self.position + 1)
  465. .first()
  466. )
  467. def get_sign_content(self):
  468. pattern = r"/files/([a-f0-9\-]+)/image-preview"
  469. text = self.content
  470. matches = re.finditer(pattern, text)
  471. signed_urls = []
  472. for match in matches:
  473. upload_file_id = match.group(1)
  474. nonce = os.urandom(16).hex()
  475. timestamp = str(int(time.time()))
  476. data_to_sign = f"image-preview|{upload_file_id}|{timestamp}|{nonce}"
  477. secret_key = dify_config.SECRET_KEY.encode() if dify_config.SECRET_KEY else b""
  478. sign = hmac.new(secret_key, data_to_sign.encode(), hashlib.sha256).digest()
  479. encoded_sign = base64.urlsafe_b64encode(sign).decode()
  480. params = f"timestamp={timestamp}&nonce={nonce}&sign={encoded_sign}"
  481. signed_url = f"{match.group(0)}?{params}"
  482. signed_urls.append((match.start(), match.end(), signed_url))
  483. # Reconstruct the text with signed URLs
  484. offset = 0
  485. for start, end, signed_url in signed_urls:
  486. text = text[: start + offset] + signed_url + text[end + offset :]
  487. offset += len(signed_url) - (end - start)
  488. return text
  489. class AppDatasetJoin(db.Model):
  490. __tablename__ = "app_dataset_joins"
  491. __table_args__ = (
  492. db.PrimaryKeyConstraint("id", name="app_dataset_join_pkey"),
  493. db.Index("app_dataset_join_app_dataset_idx", "dataset_id", "app_id"),
  494. )
  495. id = db.Column(StringUUID, primary_key=True, nullable=False, server_default=db.text("uuid_generate_v4()"))
  496. app_id = db.Column(StringUUID, nullable=False)
  497. dataset_id = db.Column(StringUUID, nullable=False)
  498. created_at = db.Column(db.DateTime, nullable=False, server_default=db.func.current_timestamp())
  499. @property
  500. def app(self):
  501. return db.session.get(App, self.app_id)
  502. class DatasetQuery(db.Model):
  503. __tablename__ = "dataset_queries"
  504. __table_args__ = (
  505. db.PrimaryKeyConstraint("id", name="dataset_query_pkey"),
  506. db.Index("dataset_query_dataset_id_idx", "dataset_id"),
  507. )
  508. id = db.Column(StringUUID, primary_key=True, nullable=False, server_default=db.text("uuid_generate_v4()"))
  509. dataset_id = db.Column(StringUUID, nullable=False)
  510. content = db.Column(db.Text, nullable=False)
  511. source = db.Column(db.String(255), nullable=False)
  512. source_app_id = db.Column(StringUUID, nullable=True)
  513. created_by_role = db.Column(db.String, nullable=False)
  514. created_by = db.Column(StringUUID, nullable=False)
  515. created_at = db.Column(db.DateTime, nullable=False, server_default=db.func.current_timestamp())
  516. class DatasetKeywordTable(db.Model):
  517. __tablename__ = "dataset_keyword_tables"
  518. __table_args__ = (
  519. db.PrimaryKeyConstraint("id", name="dataset_keyword_table_pkey"),
  520. db.Index("dataset_keyword_table_dataset_id_idx", "dataset_id"),
  521. )
  522. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  523. dataset_id = db.Column(StringUUID, nullable=False, unique=True)
  524. keyword_table = db.Column(db.Text, nullable=False)
  525. data_source_type = db.Column(
  526. db.String(255), nullable=False, server_default=db.text("'database'::character varying")
  527. )
  528. @property
  529. def keyword_table_dict(self):
  530. class SetDecoder(json.JSONDecoder):
  531. def __init__(self, *args, **kwargs):
  532. super().__init__(object_hook=self.object_hook, *args, **kwargs)
  533. def object_hook(self, dct):
  534. if isinstance(dct, dict):
  535. for keyword, node_idxs in dct.items():
  536. if isinstance(node_idxs, list):
  537. dct[keyword] = set(node_idxs)
  538. return dct
  539. # get dataset
  540. dataset = Dataset.query.filter_by(id=self.dataset_id).first()
  541. if not dataset:
  542. return None
  543. if self.data_source_type == "database":
  544. return json.loads(self.keyword_table, cls=SetDecoder) if self.keyword_table else None
  545. else:
  546. file_key = "keyword_files/" + dataset.tenant_id + "/" + self.dataset_id + ".txt"
  547. try:
  548. keyword_table_text = storage.load_once(file_key)
  549. if keyword_table_text:
  550. return json.loads(keyword_table_text.decode("utf-8"), cls=SetDecoder)
  551. return None
  552. except Exception as e:
  553. logging.exception(str(e))
  554. return None
  555. class Embedding(db.Model):
  556. __tablename__ = "embeddings"
  557. __table_args__ = (
  558. db.PrimaryKeyConstraint("id", name="embedding_pkey"),
  559. db.UniqueConstraint("model_name", "hash", "provider_name", name="embedding_hash_idx"),
  560. db.Index("created_at_idx", "created_at"),
  561. )
  562. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  563. model_name = db.Column(
  564. db.String(255), nullable=False, server_default=db.text("'text-embedding-ada-002'::character varying")
  565. )
  566. hash = db.Column(db.String(64), nullable=False)
  567. embedding = db.Column(db.LargeBinary, nullable=False)
  568. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  569. provider_name = db.Column(db.String(255), nullable=False, server_default=db.text("''::character varying"))
  570. def set_embedding(self, embedding_data: list[float]):
  571. self.embedding = pickle.dumps(embedding_data, protocol=pickle.HIGHEST_PROTOCOL)
  572. def get_embedding(self) -> list[float]:
  573. return pickle.loads(self.embedding)
  574. class DatasetCollectionBinding(db.Model):
  575. __tablename__ = "dataset_collection_bindings"
  576. __table_args__ = (
  577. db.PrimaryKeyConstraint("id", name="dataset_collection_bindings_pkey"),
  578. db.Index("provider_model_name_idx", "provider_name", "model_name"),
  579. )
  580. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  581. provider_name = db.Column(db.String(40), nullable=False)
  582. model_name = db.Column(db.String(255), nullable=False)
  583. type = db.Column(db.String(40), server_default=db.text("'dataset'::character varying"), nullable=False)
  584. collection_name = db.Column(db.String(64), nullable=False)
  585. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  586. class DatasetPermission(db.Model):
  587. __tablename__ = "dataset_permissions"
  588. __table_args__ = (
  589. db.PrimaryKeyConstraint("id", name="dataset_permission_pkey"),
  590. db.Index("idx_dataset_permissions_dataset_id", "dataset_id"),
  591. db.Index("idx_dataset_permissions_account_id", "account_id"),
  592. db.Index("idx_dataset_permissions_tenant_id", "tenant_id"),
  593. )
  594. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"), primary_key=True)
  595. dataset_id = db.Column(StringUUID, nullable=False)
  596. account_id = db.Column(StringUUID, nullable=False)
  597. tenant_id = db.Column(StringUUID, nullable=False)
  598. has_permission = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  599. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))