dataset.py 59 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480
  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 typing import Any, cast
  13. from sqlalchemy import func
  14. from sqlalchemy.dialects.postgresql import JSONB
  15. from sqlalchemy.orm import Mapped
  16. from configs import dify_config
  17. from core.rag.index_processor.constant.built_in_field import BuiltInField, MetadataDataSource
  18. from core.rag.retrieval.retrieval_methods import RetrievalMethod
  19. from extensions.ext_storage import storage
  20. from services.entities.knowledge_entities.knowledge_entities import ParentMode, Rule
  21. from .account import Account
  22. from .engine import db
  23. from .model import App, Tag, TagBinding, UploadFile
  24. from .types import StringUUID
  25. class DatasetPermissionEnum(enum.StrEnum):
  26. ONLY_ME = "only_me"
  27. ALL_TEAM = "all_team_members"
  28. PARTIAL_TEAM = "partial_members"
  29. class Dataset(db.Model): # type: ignore[name-defined]
  30. __tablename__ = "datasets"
  31. __table_args__ = (
  32. db.PrimaryKeyConstraint("id", name="dataset_pkey"),
  33. db.Index("dataset_tenant_idx", "tenant_id"),
  34. db.Index("retrieval_model_idx", "retrieval_model", postgresql_using="gin"),
  35. )
  36. INDEXING_TECHNIQUE_LIST = ["high_quality", "economy", None]
  37. PROVIDER_LIST = ["vendor", "external", None]
  38. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  39. tenant_id = db.Column(StringUUID, nullable=False)
  40. name = db.Column(db.String(255), nullable=False)
  41. description = db.Column(db.Text, nullable=True)
  42. provider = db.Column(db.String(255), nullable=False, server_default=db.text("'vendor'::character varying"))
  43. permission = db.Column(db.String(255), nullable=False, server_default=db.text("'only_me'::character varying"))
  44. data_source_type = db.Column(db.String(255))
  45. indexing_technique = db.Column(db.String(255), nullable=True)
  46. index_struct = db.Column(db.Text, nullable=True)
  47. created_by = db.Column(StringUUID, nullable=False)
  48. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  49. updated_by = db.Column(StringUUID, nullable=True)
  50. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  51. embedding_model = db.Column(db.String(255), nullable=True)
  52. embedding_model_provider = db.Column(db.String(255), nullable=True)
  53. collection_binding_id = db.Column(StringUUID, nullable=True)
  54. retrieval_model = db.Column(JSONB, nullable=True)
  55. built_in_field_enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  56. @property
  57. def dataset_keyword_table(self):
  58. dataset_keyword_table = (
  59. db.session.query(DatasetKeywordTable).filter(DatasetKeywordTable.dataset_id == self.id).first()
  60. )
  61. if dataset_keyword_table:
  62. return dataset_keyword_table
  63. return None
  64. @property
  65. def index_struct_dict(self):
  66. return json.loads(self.index_struct) if self.index_struct else None
  67. @property
  68. def external_retrieval_model(self):
  69. default_retrieval_model = {
  70. "top_k": 2,
  71. "score_threshold": 0.0,
  72. }
  73. return self.retrieval_model or default_retrieval_model
  74. @property
  75. def created_by_account(self):
  76. return db.session.get(Account, self.created_by)
  77. @property
  78. def latest_process_rule(self):
  79. return (
  80. DatasetProcessRule.query.filter(DatasetProcessRule.dataset_id == self.id)
  81. .order_by(DatasetProcessRule.created_at.desc())
  82. .first()
  83. )
  84. @property
  85. def app_count(self):
  86. return (
  87. db.session.query(func.count(AppDatasetJoin.id))
  88. .filter(AppDatasetJoin.dataset_id == self.id, App.id == AppDatasetJoin.app_id)
  89. .scalar()
  90. )
  91. @property
  92. def document_count(self):
  93. return db.session.query(func.count(Document.id)).filter(Document.dataset_id == self.id).scalar()
  94. @property
  95. def available_document_count(self):
  96. return (
  97. db.session.query(func.count(Document.id))
  98. .filter(
  99. Document.dataset_id == self.id,
  100. Document.indexing_status == "completed",
  101. Document.enabled == True,
  102. Document.archived == False,
  103. )
  104. .scalar()
  105. )
  106. @property
  107. def available_segment_count(self):
  108. return (
  109. db.session.query(func.count(DocumentSegment.id))
  110. .filter(
  111. DocumentSegment.dataset_id == self.id,
  112. DocumentSegment.status == "completed",
  113. DocumentSegment.enabled == True,
  114. )
  115. .scalar()
  116. )
  117. @property
  118. def word_count(self):
  119. return (
  120. Document.query.with_entities(func.coalesce(func.sum(Document.word_count)))
  121. .filter(Document.dataset_id == self.id)
  122. .scalar()
  123. )
  124. @property
  125. def doc_form(self):
  126. document = db.session.query(Document).filter(Document.dataset_id == self.id).first()
  127. if document:
  128. return document.doc_form
  129. return None
  130. @property
  131. def retrieval_model_dict(self):
  132. default_retrieval_model = {
  133. "search_method": RetrievalMethod.SEMANTIC_SEARCH.value,
  134. "reranking_enable": False,
  135. "reranking_model": {"reranking_provider_name": "", "reranking_model_name": ""},
  136. "top_k": 2,
  137. "score_threshold_enabled": False,
  138. }
  139. return self.retrieval_model or default_retrieval_model
  140. @property
  141. def tags(self):
  142. tags = (
  143. db.session.query(Tag)
  144. .join(TagBinding, Tag.id == TagBinding.tag_id)
  145. .filter(
  146. TagBinding.target_id == self.id,
  147. TagBinding.tenant_id == self.tenant_id,
  148. Tag.tenant_id == self.tenant_id,
  149. Tag.type == "knowledge",
  150. )
  151. .all()
  152. )
  153. return tags or []
  154. @property
  155. def external_knowledge_info(self):
  156. if self.provider != "external":
  157. return None
  158. external_knowledge_binding = (
  159. db.session.query(ExternalKnowledgeBindings).filter(ExternalKnowledgeBindings.dataset_id == self.id).first()
  160. )
  161. if not external_knowledge_binding:
  162. return None
  163. external_knowledge_api = (
  164. db.session.query(ExternalKnowledgeApis)
  165. .filter(ExternalKnowledgeApis.id == external_knowledge_binding.external_knowledge_api_id)
  166. .first()
  167. )
  168. if not external_knowledge_api:
  169. return None
  170. return {
  171. "external_knowledge_id": external_knowledge_binding.external_knowledge_id,
  172. "external_knowledge_api_id": external_knowledge_api.id,
  173. "external_knowledge_api_name": external_knowledge_api.name,
  174. "external_knowledge_api_endpoint": json.loads(external_knowledge_api.settings).get("endpoint", ""),
  175. }
  176. @property
  177. def doc_metadata(self):
  178. dataset_metadatas = db.session.query(DatasetMetadata).filter(DatasetMetadata.dataset_id == self.id).all()
  179. doc_metadata = [
  180. {
  181. "id": dataset_metadata.id,
  182. "name": dataset_metadata.name,
  183. "type": dataset_metadata.type,
  184. }
  185. for dataset_metadata in dataset_metadatas
  186. ]
  187. if self.built_in_field_enabled:
  188. doc_metadata.append(
  189. {
  190. "id": "built-in",
  191. "name": BuiltInField.document_name.value,
  192. "type": "string",
  193. }
  194. )
  195. doc_metadata.append(
  196. {
  197. "id": "built-in",
  198. "name": BuiltInField.uploader.value,
  199. "type": "string",
  200. }
  201. )
  202. doc_metadata.append(
  203. {
  204. "id": "built-in",
  205. "name": BuiltInField.upload_date.value,
  206. "type": "time",
  207. }
  208. )
  209. doc_metadata.append(
  210. {
  211. "id": "built-in",
  212. "name": BuiltInField.last_update_date.value,
  213. "type": "time",
  214. }
  215. )
  216. doc_metadata.append(
  217. {
  218. "id": "built-in",
  219. "name": BuiltInField.source.value,
  220. "type": "string",
  221. }
  222. )
  223. return doc_metadata
  224. @staticmethod
  225. def gen_collection_name_by_id(dataset_id: str) -> str:
  226. normalized_dataset_id = dataset_id.replace("-", "_")
  227. return f"Vector_index_{normalized_dataset_id}_Node"
  228. class DatasetProcessRule(db.Model): # type: ignore[name-defined]
  229. __tablename__ = "dataset_process_rules"
  230. __table_args__ = (
  231. db.PrimaryKeyConstraint("id", name="dataset_process_rule_pkey"),
  232. db.Index("dataset_process_rule_dataset_id_idx", "dataset_id"),
  233. )
  234. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  235. dataset_id = db.Column(StringUUID, nullable=False)
  236. mode = db.Column(db.String(255), nullable=False, server_default=db.text("'automatic'::character varying"))
  237. rules = db.Column(db.Text, nullable=True)
  238. created_by = db.Column(StringUUID, nullable=False)
  239. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  240. MODES = ["automatic", "custom", "hierarchical"]
  241. PRE_PROCESSING_RULES = ["remove_stopwords", "remove_extra_spaces", "remove_urls_emails"]
  242. AUTOMATIC_RULES: dict[str, Any] = {
  243. "pre_processing_rules": [
  244. {"id": "remove_extra_spaces", "enabled": True},
  245. {"id": "remove_urls_emails", "enabled": False},
  246. ],
  247. "segmentation": {"delimiter": "\n", "max_tokens": 500, "chunk_overlap": 50},
  248. }
  249. def to_dict(self):
  250. return {
  251. "id": self.id,
  252. "dataset_id": self.dataset_id,
  253. "mode": self.mode,
  254. "rules": self.rules_dict,
  255. }
  256. @property
  257. def rules_dict(self):
  258. try:
  259. return json.loads(self.rules) if self.rules else None
  260. except JSONDecodeError:
  261. return None
  262. class Document(db.Model): # type: ignore[name-defined]
  263. __tablename__ = "documents"
  264. __table_args__ = (
  265. db.PrimaryKeyConstraint("id", name="document_pkey"),
  266. db.Index("document_dataset_id_idx", "dataset_id"),
  267. db.Index("document_is_paused_idx", "is_paused"),
  268. db.Index("document_tenant_idx", "tenant_id"),
  269. db.Index("document_metadata_idx", "doc_metadata", postgresql_using="gin"),
  270. )
  271. # initial fields
  272. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  273. tenant_id = db.Column(StringUUID, nullable=False)
  274. dataset_id = db.Column(StringUUID, nullable=False)
  275. position = db.Column(db.Integer, nullable=False)
  276. data_source_type = db.Column(db.String(255), nullable=False)
  277. data_source_info = db.Column(db.Text, nullable=True)
  278. dataset_process_rule_id = db.Column(StringUUID, nullable=True)
  279. batch = db.Column(db.String(255), nullable=False)
  280. name = db.Column(db.String(255), nullable=False)
  281. created_from = db.Column(db.String(255), nullable=False)
  282. created_by = db.Column(StringUUID, nullable=False)
  283. created_api_request_id = db.Column(StringUUID, nullable=True)
  284. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  285. # start processing
  286. processing_started_at = db.Column(db.DateTime, nullable=True)
  287. # parsing
  288. file_id = db.Column(db.Text, nullable=True)
  289. word_count = db.Column(db.Integer, nullable=True)
  290. parsing_completed_at = db.Column(db.DateTime, nullable=True)
  291. # cleaning
  292. cleaning_completed_at = db.Column(db.DateTime, nullable=True)
  293. # split
  294. splitting_completed_at = db.Column(db.DateTime, nullable=True)
  295. # indexing
  296. tokens = db.Column(db.Integer, nullable=True)
  297. indexing_latency = db.Column(db.Float, nullable=True)
  298. completed_at = db.Column(db.DateTime, nullable=True)
  299. # pause
  300. is_paused = db.Column(db.Boolean, nullable=True, server_default=db.text("false"))
  301. paused_by = db.Column(StringUUID, nullable=True)
  302. paused_at = db.Column(db.DateTime, nullable=True)
  303. # error
  304. error = db.Column(db.Text, nullable=True)
  305. stopped_at = db.Column(db.DateTime, nullable=True)
  306. # basic fields
  307. indexing_status = db.Column(db.String(255), nullable=False, server_default=db.text("'waiting'::character varying"))
  308. enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  309. disabled_at = db.Column(db.DateTime, nullable=True)
  310. disabled_by = db.Column(StringUUID, nullable=True)
  311. archived = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  312. archived_reason = db.Column(db.String(255), nullable=True)
  313. archived_by = db.Column(StringUUID, nullable=True)
  314. archived_at = db.Column(db.DateTime, nullable=True)
  315. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  316. doc_type = db.Column(db.String(40), nullable=True)
  317. doc_metadata = db.Column(JSONB, nullable=True)
  318. doc_form = db.Column(db.String(255), nullable=False, server_default=db.text("'text_model'::character varying"))
  319. doc_language = db.Column(db.String(255), nullable=True)
  320. DATA_SOURCES = ["upload_file", "notion_import", "website_crawl"]
  321. @property
  322. def display_status(self):
  323. status = None
  324. if self.indexing_status == "waiting":
  325. status = "queuing"
  326. elif self.indexing_status not in {"completed", "error", "waiting"} and self.is_paused:
  327. status = "paused"
  328. elif self.indexing_status in {"parsing", "cleaning", "splitting", "indexing"}:
  329. status = "indexing"
  330. elif self.indexing_status == "error":
  331. status = "error"
  332. elif self.indexing_status == "completed" and not self.archived and self.enabled:
  333. status = "available"
  334. elif self.indexing_status == "completed" and not self.archived and not self.enabled:
  335. status = "disabled"
  336. elif self.indexing_status == "completed" and self.archived:
  337. status = "archived"
  338. return status
  339. @property
  340. def data_source_info_dict(self):
  341. if self.data_source_info:
  342. try:
  343. data_source_info_dict = json.loads(self.data_source_info)
  344. except JSONDecodeError:
  345. data_source_info_dict = {}
  346. return data_source_info_dict
  347. return None
  348. @property
  349. def data_source_detail_dict(self):
  350. if self.data_source_info:
  351. if self.data_source_type == "upload_file":
  352. data_source_info_dict = json.loads(self.data_source_info)
  353. file_detail = (
  354. db.session.query(UploadFile)
  355. .filter(UploadFile.id == data_source_info_dict["upload_file_id"])
  356. .one_or_none()
  357. )
  358. if file_detail:
  359. return {
  360. "upload_file": {
  361. "id": file_detail.id,
  362. "name": file_detail.name,
  363. "size": file_detail.size,
  364. "extension": file_detail.extension,
  365. "mime_type": file_detail.mime_type,
  366. "created_by": file_detail.created_by,
  367. "created_at": file_detail.created_at.timestamp(),
  368. }
  369. }
  370. elif self.data_source_type in {"notion_import", "website_crawl"}:
  371. return json.loads(self.data_source_info)
  372. return {}
  373. @property
  374. def average_segment_length(self):
  375. if self.word_count and self.word_count != 0 and self.segment_count and self.segment_count != 0:
  376. return self.word_count // self.segment_count
  377. return 0
  378. @property
  379. def dataset_process_rule(self):
  380. if self.dataset_process_rule_id:
  381. return db.session.get(DatasetProcessRule, self.dataset_process_rule_id)
  382. return None
  383. @property
  384. def dataset(self):
  385. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).one_or_none()
  386. @property
  387. def segment_count(self):
  388. return DocumentSegment.query.filter(DocumentSegment.document_id == self.id).count()
  389. @property
  390. def hit_count(self):
  391. return (
  392. DocumentSegment.query.with_entities(func.coalesce(func.sum(DocumentSegment.hit_count)))
  393. .filter(DocumentSegment.document_id == self.id)
  394. .scalar()
  395. )
  396. @property
  397. def uploader(self):
  398. user = db.session.query(Account).filter(Account.id == self.created_by).first()
  399. return user.name if user else None
  400. @property
  401. def upload_date(self):
  402. return self.created_at
  403. @property
  404. def last_update_date(self):
  405. return self.updated_at
  406. @property
  407. def doc_metadata_details(self):
  408. if self.doc_metadata:
  409. document_metadatas = (
  410. db.session.query(DatasetMetadata)
  411. .join(DatasetMetadataBinding, DatasetMetadataBinding.metadata_id == DatasetMetadata.id)
  412. .filter(
  413. DatasetMetadataBinding.dataset_id == self.dataset_id, DatasetMetadataBinding.document_id == self.id
  414. )
  415. .all()
  416. )
  417. metadata_list = []
  418. for metadata in document_metadatas:
  419. metadata_dict = {
  420. "id": metadata.id,
  421. "name": metadata.name,
  422. "type": metadata.type,
  423. "value": self.doc_metadata.get(metadata.name),
  424. }
  425. metadata_list.append(metadata_dict)
  426. # deal built-in fields
  427. metadata_list.extend(self.get_built_in_fields())
  428. return metadata_list
  429. return None
  430. @property
  431. def process_rule_dict(self):
  432. if self.dataset_process_rule_id:
  433. return self.dataset_process_rule.to_dict()
  434. return None
  435. def get_built_in_fields(self):
  436. built_in_fields = []
  437. built_in_fields.append(
  438. {
  439. "id": "built-in",
  440. "name": BuiltInField.document_name,
  441. "type": "string",
  442. "value": self.name,
  443. }
  444. )
  445. built_in_fields.append(
  446. {
  447. "id": "built-in",
  448. "name": BuiltInField.uploader,
  449. "type": "string",
  450. "value": self.uploader,
  451. }
  452. )
  453. built_in_fields.append(
  454. {
  455. "id": "built-in",
  456. "name": BuiltInField.upload_date,
  457. "type": "time",
  458. "value": self.created_at.timestamp(),
  459. }
  460. )
  461. built_in_fields.append(
  462. {
  463. "id": "built-in",
  464. "name": BuiltInField.last_update_date,
  465. "type": "time",
  466. "value": self.updated_at.timestamp(),
  467. }
  468. )
  469. built_in_fields.append(
  470. {
  471. "id": "built-in",
  472. "name": BuiltInField.source,
  473. "type": "string",
  474. "value": MetadataDataSource[self.data_source_type].value,
  475. }
  476. )
  477. return built_in_fields
  478. def to_dict(self):
  479. return {
  480. "id": self.id,
  481. "tenant_id": self.tenant_id,
  482. "dataset_id": self.dataset_id,
  483. "position": self.position,
  484. "data_source_type": self.data_source_type,
  485. "data_source_info": self.data_source_info,
  486. "dataset_process_rule_id": self.dataset_process_rule_id,
  487. "batch": self.batch,
  488. "name": self.name,
  489. "created_from": self.created_from,
  490. "created_by": self.created_by,
  491. "created_api_request_id": self.created_api_request_id,
  492. "created_at": self.created_at,
  493. "processing_started_at": self.processing_started_at,
  494. "file_id": self.file_id,
  495. "word_count": self.word_count,
  496. "parsing_completed_at": self.parsing_completed_at,
  497. "cleaning_completed_at": self.cleaning_completed_at,
  498. "splitting_completed_at": self.splitting_completed_at,
  499. "tokens": self.tokens,
  500. "indexing_latency": self.indexing_latency,
  501. "completed_at": self.completed_at,
  502. "is_paused": self.is_paused,
  503. "paused_by": self.paused_by,
  504. "paused_at": self.paused_at,
  505. "error": self.error,
  506. "stopped_at": self.stopped_at,
  507. "indexing_status": self.indexing_status,
  508. "enabled": self.enabled,
  509. "disabled_at": self.disabled_at,
  510. "disabled_by": self.disabled_by,
  511. "archived": self.archived,
  512. "archived_reason": self.archived_reason,
  513. "archived_by": self.archived_by,
  514. "archived_at": self.archived_at,
  515. "updated_at": self.updated_at,
  516. "doc_type": self.doc_type,
  517. "doc_metadata": self.doc_metadata,
  518. "doc_form": self.doc_form,
  519. "doc_language": self.doc_language,
  520. "display_status": self.display_status,
  521. "data_source_info_dict": self.data_source_info_dict,
  522. "average_segment_length": self.average_segment_length,
  523. "dataset_process_rule": self.dataset_process_rule.to_dict() if self.dataset_process_rule else None,
  524. "dataset": self.dataset.to_dict() if self.dataset else None,
  525. "segment_count": self.segment_count,
  526. "hit_count": self.hit_count,
  527. }
  528. @classmethod
  529. def from_dict(cls, data: dict):
  530. return cls(
  531. id=data.get("id"),
  532. tenant_id=data.get("tenant_id"),
  533. dataset_id=data.get("dataset_id"),
  534. position=data.get("position"),
  535. data_source_type=data.get("data_source_type"),
  536. data_source_info=data.get("data_source_info"),
  537. dataset_process_rule_id=data.get("dataset_process_rule_id"),
  538. batch=data.get("batch"),
  539. name=data.get("name"),
  540. created_from=data.get("created_from"),
  541. created_by=data.get("created_by"),
  542. created_api_request_id=data.get("created_api_request_id"),
  543. created_at=data.get("created_at"),
  544. processing_started_at=data.get("processing_started_at"),
  545. file_id=data.get("file_id"),
  546. word_count=data.get("word_count"),
  547. parsing_completed_at=data.get("parsing_completed_at"),
  548. cleaning_completed_at=data.get("cleaning_completed_at"),
  549. splitting_completed_at=data.get("splitting_completed_at"),
  550. tokens=data.get("tokens"),
  551. indexing_latency=data.get("indexing_latency"),
  552. completed_at=data.get("completed_at"),
  553. is_paused=data.get("is_paused"),
  554. paused_by=data.get("paused_by"),
  555. paused_at=data.get("paused_at"),
  556. error=data.get("error"),
  557. stopped_at=data.get("stopped_at"),
  558. indexing_status=data.get("indexing_status"),
  559. enabled=data.get("enabled"),
  560. disabled_at=data.get("disabled_at"),
  561. disabled_by=data.get("disabled_by"),
  562. archived=data.get("archived"),
  563. archived_reason=data.get("archived_reason"),
  564. archived_by=data.get("archived_by"),
  565. archived_at=data.get("archived_at"),
  566. updated_at=data.get("updated_at"),
  567. doc_type=data.get("doc_type"),
  568. doc_metadata=data.get("doc_metadata"),
  569. doc_form=data.get("doc_form"),
  570. doc_language=data.get("doc_language"),
  571. )
  572. class Template(db.Model): # type: ignore[name-defined]
  573. __tablename__ = "template"
  574. __table_args__ = (
  575. db.PrimaryKeyConstraint("id", name="template_pkey"),
  576. db.Index("template_dataset_id_idx", "dataset_id"),
  577. db.Index("template_is_paused_idx", "is_paused"),
  578. db.Index("template_tenant_idx", "tenant_id"),
  579. db.Index("template_metadata_idx", "doc_metadata", postgresql_using="gin"),
  580. )
  581. # initial fields
  582. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  583. tenant_id = db.Column(StringUUID, nullable=False)
  584. dataset_id = db.Column(StringUUID, nullable=False)
  585. position = db.Column(db.Integer, nullable=False)
  586. data_source_type = db.Column(db.String(255), nullable=False)
  587. data_source_info = db.Column(db.Text, nullable=True)
  588. dataset_process_rule_id = db.Column(StringUUID, nullable=True)
  589. batch = db.Column(db.String(255), nullable=False)
  590. name = db.Column(db.String(255), nullable=False)
  591. created_from = db.Column(db.String(255), nullable=False)
  592. created_by = db.Column(StringUUID, nullable=False)
  593. created_api_request_id = db.Column(StringUUID, nullable=True)
  594. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  595. # start processing
  596. processing_started_at = db.Column(db.DateTime, nullable=True)
  597. # parsing
  598. file_id = db.Column(db.Text, nullable=True)
  599. file_url = db.Column(db.Text, nullable=True)
  600. word_count = db.Column(db.Integer, nullable=True)
  601. parsing_completed_at = db.Column(db.DateTime, nullable=True)
  602. # cleaning
  603. cleaning_completed_at = db.Column(db.DateTime, nullable=True)
  604. # split
  605. splitting_completed_at = db.Column(db.DateTime, nullable=True)
  606. # indexing
  607. tokens = db.Column(db.Integer, nullable=True)
  608. indexing_latency = db.Column(db.Float, nullable=True)
  609. completed_at = db.Column(db.DateTime, nullable=True)
  610. # pause
  611. is_paused = db.Column(db.Boolean, nullable=True, server_default=db.text("false"))
  612. paused_by = db.Column(StringUUID, nullable=True)
  613. paused_at = db.Column(db.DateTime, nullable=True)
  614. # error
  615. error = db.Column(db.Text, nullable=True)
  616. stopped_at = db.Column(db.DateTime, nullable=True)
  617. # basic fields
  618. indexing_status = db.Column(db.String(255), nullable=False, server_default=db.text("'waiting'::character varying"))
  619. enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  620. disabled_at = db.Column(db.DateTime, nullable=True)
  621. disabled_by = db.Column(StringUUID, nullable=True)
  622. archived = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  623. archived_reason = db.Column(db.String(255), nullable=True)
  624. archived_by = db.Column(StringUUID, nullable=True)
  625. archived_at = db.Column(db.DateTime, nullable=True)
  626. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  627. doc_type = db.Column(db.String(40), nullable=True)
  628. doc_metadata = db.Column(JSONB, nullable=True)
  629. doc_form = db.Column(db.String(255), nullable=False, server_default=db.text("'text_model'::character varying"))
  630. doc_language = db.Column(db.String(255), nullable=True)
  631. DATA_SOURCES = ["upload_file"]
  632. @property
  633. def display_status(self):
  634. status = None
  635. if self.indexing_status == "waiting":
  636. status = "queuing"
  637. elif self.indexing_status not in {"completed", "error", "waiting"} and self.is_paused:
  638. status = "paused"
  639. elif self.indexing_status in {"parsing", "cleaning", "splitting", "indexing"}:
  640. status = "indexing"
  641. elif self.indexing_status == "error":
  642. status = "error"
  643. elif self.indexing_status == "completed" and not self.archived and self.enabled:
  644. status = "available"
  645. elif self.indexing_status == "completed" and not self.archived and not self.enabled:
  646. status = "disabled"
  647. elif self.indexing_status == "completed" and self.archived:
  648. status = "archived"
  649. return status
  650. @property
  651. def data_source_info_dict(self):
  652. if self.data_source_info:
  653. try:
  654. data_source_info_dict = json.loads(self.data_source_info)
  655. except JSONDecodeError:
  656. data_source_info_dict = {}
  657. return data_source_info_dict
  658. return None
  659. @property
  660. def data_source_detail_dict(self):
  661. if self.data_source_info:
  662. if self.data_source_type == "upload_file":
  663. data_source_info_dict = json.loads(self.data_source_info)
  664. file_detail = (
  665. db.session.query(UploadFile)
  666. .filter(UploadFile.id == data_source_info_dict["upload_file_id"])
  667. .one_or_none()
  668. )
  669. if file_detail:
  670. return {
  671. "upload_file": {
  672. "id": file_detail.id,
  673. "name": file_detail.name,
  674. "size": file_detail.size,
  675. "extension": file_detail.extension,
  676. "mime_type": file_detail.mime_type,
  677. "created_by": file_detail.created_by,
  678. "created_at": file_detail.created_at.timestamp(),
  679. }
  680. }
  681. elif self.data_source_type in {"notion_import", "website_crawl"}:
  682. return json.loads(self.data_source_info)
  683. return {}
  684. @property
  685. def average_segment_length(self):
  686. if self.word_count and self.word_count != 0 and self.segment_count and self.segment_count != 0:
  687. return self.word_count // self.segment_count
  688. return 0
  689. @property
  690. def dataset_process_rule(self):
  691. if self.dataset_process_rule_id:
  692. return db.session.get(DatasetProcessRule, self.dataset_process_rule_id)
  693. return None
  694. @property
  695. def dataset(self):
  696. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).one_or_none()
  697. @property
  698. def segment_count(self):
  699. return DocumentSegment.query.filter(DocumentSegment.document_id == self.id).count()
  700. @property
  701. def hit_count(self):
  702. return (
  703. DocumentSegment.query.with_entities(func.coalesce(func.sum(DocumentSegment.hit_count)))
  704. .filter(DocumentSegment.document_id == self.id)
  705. .scalar()
  706. )
  707. @property
  708. def uploader(self):
  709. user = db.session.query(Account).filter(Account.id == self.created_by).first()
  710. return user.name if user else None
  711. @property
  712. def upload_date(self):
  713. return self.created_at
  714. @property
  715. def last_update_date(self):
  716. return self.updated_at
  717. @property
  718. def doc_metadata_details(self):
  719. if self.doc_metadata:
  720. document_metadatas = (
  721. db.session.query(DatasetMetadata)
  722. .join(DatasetMetadataBinding, DatasetMetadataBinding.metadata_id == DatasetMetadata.id)
  723. .filter(
  724. DatasetMetadataBinding.dataset_id == self.dataset_id, DatasetMetadataBinding.document_id == self.id
  725. )
  726. .all()
  727. )
  728. metadata_list = []
  729. for metadata in document_metadatas:
  730. metadata_dict = {
  731. "id": metadata.id,
  732. "name": metadata.name,
  733. "type": metadata.type,
  734. "value": self.doc_metadata.get(metadata.name),
  735. }
  736. metadata_list.append(metadata_dict)
  737. # deal built-in fields
  738. metadata_list.extend(self.get_built_in_fields())
  739. return metadata_list
  740. return None
  741. @property
  742. def process_rule_dict(self):
  743. if self.dataset_process_rule_id:
  744. return self.dataset_process_rule.to_dict()
  745. return None
  746. def get_built_in_fields(self):
  747. built_in_fields = []
  748. built_in_fields.append(
  749. {
  750. "id": "built-in",
  751. "name": BuiltInField.document_name,
  752. "type": "string",
  753. "value": self.name,
  754. }
  755. )
  756. built_in_fields.append(
  757. {
  758. "id": "built-in",
  759. "name": BuiltInField.uploader,
  760. "type": "string",
  761. "value": self.uploader,
  762. }
  763. )
  764. built_in_fields.append(
  765. {
  766. "id": "built-in",
  767. "name": BuiltInField.upload_date,
  768. "type": "time",
  769. "value": self.created_at.timestamp(),
  770. }
  771. )
  772. built_in_fields.append(
  773. {
  774. "id": "built-in",
  775. "name": BuiltInField.last_update_date,
  776. "type": "time",
  777. "value": self.updated_at.timestamp(),
  778. }
  779. )
  780. built_in_fields.append(
  781. {
  782. "id": "built-in",
  783. "name": BuiltInField.source,
  784. "type": "string",
  785. "value": MetadataDataSource[self.data_source_type].value,
  786. }
  787. )
  788. return built_in_fields
  789. def to_dict(self):
  790. return {
  791. "id": self.id,
  792. "tenant_id": self.tenant_id,
  793. "dataset_id": self.dataset_id,
  794. "position": self.position,
  795. "data_source_type": self.data_source_type,
  796. "data_source_info": self.data_source_info,
  797. "dataset_process_rule_id": self.dataset_process_rule_id,
  798. "batch": self.batch,
  799. "name": self.name,
  800. "created_from": self.created_from,
  801. "created_by": self.created_by,
  802. "created_api_request_id": self.created_api_request_id,
  803. "created_at": self.created_at,
  804. "processing_started_at": self.processing_started_at,
  805. "file_id": self.file_id,
  806. "word_count": self.word_count,
  807. "parsing_completed_at": self.parsing_completed_at,
  808. "cleaning_completed_at": self.cleaning_completed_at,
  809. "splitting_completed_at": self.splitting_completed_at,
  810. "tokens": self.tokens,
  811. "indexing_latency": self.indexing_latency,
  812. "completed_at": self.completed_at,
  813. "is_paused": self.is_paused,
  814. "paused_by": self.paused_by,
  815. "paused_at": self.paused_at,
  816. "error": self.error,
  817. "stopped_at": self.stopped_at,
  818. "indexing_status": self.indexing_status,
  819. "enabled": self.enabled,
  820. "disabled_at": self.disabled_at,
  821. "disabled_by": self.disabled_by,
  822. "archived": self.archived,
  823. "archived_reason": self.archived_reason,
  824. "archived_by": self.archived_by,
  825. "archived_at": self.archived_at,
  826. "updated_at": self.updated_at,
  827. "doc_type": self.doc_type,
  828. "doc_metadata": self.doc_metadata,
  829. "doc_form": self.doc_form,
  830. "doc_language": self.doc_language,
  831. "display_status": self.display_status,
  832. "data_source_info_dict": self.data_source_info_dict,
  833. "average_segment_length": self.average_segment_length,
  834. "dataset_process_rule": self.dataset_process_rule.to_dict() if self.dataset_process_rule else None,
  835. "dataset": self.dataset.to_dict() if self.dataset else None,
  836. "segment_count": self.segment_count,
  837. "hit_count": self.hit_count,
  838. }
  839. @classmethod
  840. def from_dict(cls, data: dict):
  841. return cls(
  842. id=data.get("id"),
  843. tenant_id=data.get("tenant_id"),
  844. dataset_id=data.get("dataset_id"),
  845. position=data.get("position"),
  846. data_source_type=data.get("data_source_type"),
  847. data_source_info=data.get("data_source_info"),
  848. dataset_process_rule_id=data.get("dataset_process_rule_id"),
  849. batch=data.get("batch"),
  850. name=data.get("name"),
  851. created_from=data.get("created_from"),
  852. created_by=data.get("created_by"),
  853. created_api_request_id=data.get("created_api_request_id"),
  854. created_at=data.get("created_at"),
  855. processing_started_at=data.get("processing_started_at"),
  856. file_id=data.get("file_id"),
  857. word_count=data.get("word_count"),
  858. parsing_completed_at=data.get("parsing_completed_at"),
  859. cleaning_completed_at=data.get("cleaning_completed_at"),
  860. splitting_completed_at=data.get("splitting_completed_at"),
  861. tokens=data.get("tokens"),
  862. indexing_latency=data.get("indexing_latency"),
  863. completed_at=data.get("completed_at"),
  864. is_paused=data.get("is_paused"),
  865. paused_by=data.get("paused_by"),
  866. paused_at=data.get("paused_at"),
  867. error=data.get("error"),
  868. stopped_at=data.get("stopped_at"),
  869. indexing_status=data.get("indexing_status"),
  870. enabled=data.get("enabled"),
  871. disabled_at=data.get("disabled_at"),
  872. disabled_by=data.get("disabled_by"),
  873. archived=data.get("archived"),
  874. archived_reason=data.get("archived_reason"),
  875. archived_by=data.get("archived_by"),
  876. archived_at=data.get("archived_at"),
  877. updated_at=data.get("updated_at"),
  878. doc_type=data.get("doc_type"),
  879. doc_metadata=data.get("doc_metadata"),
  880. doc_form=data.get("doc_form"),
  881. doc_language=data.get("doc_language"),
  882. )
  883. class DocumentSegment(db.Model): # type: ignore[name-defined]
  884. __tablename__ = "document_segments"
  885. __table_args__ = (
  886. db.PrimaryKeyConstraint("id", name="document_segment_pkey"),
  887. db.Index("document_segment_dataset_id_idx", "dataset_id"),
  888. db.Index("document_segment_document_id_idx", "document_id"),
  889. db.Index("document_segment_tenant_dataset_idx", "dataset_id", "tenant_id"),
  890. db.Index("document_segment_tenant_document_idx", "document_id", "tenant_id"),
  891. db.Index("document_segment_dataset_node_idx", "dataset_id", "index_node_id"),
  892. db.Index("document_segment_tenant_idx", "tenant_id"),
  893. )
  894. # initial fields
  895. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  896. tenant_id = db.Column(StringUUID, nullable=False)
  897. dataset_id = db.Column(StringUUID, nullable=False)
  898. document_id = db.Column(StringUUID, nullable=False)
  899. position: Mapped[int]
  900. content = db.Column(db.Text, nullable=False)
  901. answer = db.Column(db.Text, nullable=True)
  902. word_count = db.Column(db.Integer, nullable=False)
  903. tokens = db.Column(db.Integer, nullable=False)
  904. # indexing fields
  905. keywords = db.Column(db.JSON, nullable=True)
  906. index_node_id = db.Column(db.String(255), nullable=True)
  907. index_node_hash = db.Column(db.String(255), nullable=True)
  908. # basic fields
  909. hit_count = db.Column(db.Integer, nullable=False, default=0)
  910. enabled = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  911. disabled_at = db.Column(db.DateTime, nullable=True)
  912. disabled_by = db.Column(StringUUID, nullable=True)
  913. status = db.Column(db.String(255), nullable=False, server_default=db.text("'waiting'::character varying"))
  914. created_by = db.Column(StringUUID, nullable=False)
  915. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  916. updated_by = db.Column(StringUUID, nullable=True)
  917. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  918. indexing_at = db.Column(db.DateTime, nullable=True)
  919. completed_at = db.Column(db.DateTime, nullable=True)
  920. error = db.Column(db.Text, nullable=True)
  921. stopped_at = db.Column(db.DateTime, nullable=True)
  922. @property
  923. def dataset(self):
  924. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).first()
  925. @property
  926. def document(self):
  927. return db.session.query(Document).filter(Document.id == self.document_id).first()
  928. @property
  929. def previous_segment(self):
  930. return (
  931. db.session.query(DocumentSegment)
  932. .filter(DocumentSegment.document_id == self.document_id, DocumentSegment.position == self.position - 1)
  933. .first()
  934. )
  935. @property
  936. def next_segment(self):
  937. return (
  938. db.session.query(DocumentSegment)
  939. .filter(DocumentSegment.document_id == self.document_id, DocumentSegment.position == self.position + 1)
  940. .first()
  941. )
  942. @property
  943. def child_chunks(self):
  944. process_rule = self.document.dataset_process_rule
  945. if process_rule.mode == "hierarchical":
  946. rules = Rule(**process_rule.rules_dict)
  947. if rules.parent_mode and rules.parent_mode != ParentMode.FULL_DOC:
  948. child_chunks = (
  949. db.session.query(ChildChunk)
  950. .filter(ChildChunk.segment_id == self.id)
  951. .order_by(ChildChunk.position.asc())
  952. .all()
  953. )
  954. return child_chunks or []
  955. else:
  956. return []
  957. else:
  958. return []
  959. def get_child_chunks(self):
  960. process_rule = self.document.dataset_process_rule
  961. if process_rule.mode == "hierarchical":
  962. rules = Rule(**process_rule.rules_dict)
  963. if rules.parent_mode:
  964. child_chunks = (
  965. db.session.query(ChildChunk)
  966. .filter(ChildChunk.segment_id == self.id)
  967. .order_by(ChildChunk.position.asc())
  968. .all()
  969. )
  970. return child_chunks or []
  971. else:
  972. return []
  973. else:
  974. return []
  975. @property
  976. def sign_content(self):
  977. return self.get_sign_content()
  978. def get_sign_content(self):
  979. signed_urls = []
  980. text = self.content
  981. # For data before v0.10.0
  982. pattern = r"/files/([a-f0-9\-]+)/image-preview"
  983. matches = re.finditer(pattern, text)
  984. for match in matches:
  985. upload_file_id = match.group(1)
  986. nonce = os.urandom(16).hex()
  987. timestamp = str(int(time.time()))
  988. data_to_sign = f"image-preview|{upload_file_id}|{timestamp}|{nonce}"
  989. secret_key = dify_config.SECRET_KEY.encode() if dify_config.SECRET_KEY else b""
  990. sign = hmac.new(secret_key, data_to_sign.encode(), hashlib.sha256).digest()
  991. encoded_sign = base64.urlsafe_b64encode(sign).decode()
  992. params = f"timestamp={timestamp}&nonce={nonce}&sign={encoded_sign}"
  993. signed_url = f"{match.group(0)}?{params}"
  994. signed_urls.append((match.start(), match.end(), signed_url))
  995. # For data after v0.10.0
  996. pattern = r"/files/([a-f0-9\-]+)/file-preview"
  997. matches = re.finditer(pattern, text)
  998. for match in matches:
  999. upload_file_id = match.group(1)
  1000. nonce = os.urandom(16).hex()
  1001. timestamp = str(int(time.time()))
  1002. data_to_sign = f"file-preview|{upload_file_id}|{timestamp}|{nonce}"
  1003. secret_key = dify_config.SECRET_KEY.encode() if dify_config.SECRET_KEY else b""
  1004. sign = hmac.new(secret_key, data_to_sign.encode(), hashlib.sha256).digest()
  1005. encoded_sign = base64.urlsafe_b64encode(sign).decode()
  1006. params = f"timestamp={timestamp}&nonce={nonce}&sign={encoded_sign}"
  1007. signed_url = f"{match.group(0)}?{params}"
  1008. signed_urls.append((match.start(), match.end(), signed_url))
  1009. # Reconstruct the text with signed URLs
  1010. offset = 0
  1011. for start, end, signed_url in signed_urls:
  1012. text = text[: start + offset] + signed_url + text[end + offset :]
  1013. offset += len(signed_url) - (end - start)
  1014. return text
  1015. class ChildChunk(db.Model): # type: ignore[name-defined]
  1016. __tablename__ = "child_chunks"
  1017. __table_args__ = (
  1018. db.PrimaryKeyConstraint("id", name="child_chunk_pkey"),
  1019. db.Index("child_chunk_dataset_id_idx", "tenant_id", "dataset_id", "document_id", "segment_id", "index_node_id"),
  1020. )
  1021. # initial fields
  1022. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  1023. tenant_id = db.Column(StringUUID, nullable=False)
  1024. dataset_id = db.Column(StringUUID, nullable=False)
  1025. document_id = db.Column(StringUUID, nullable=False)
  1026. segment_id = db.Column(StringUUID, nullable=False)
  1027. position = db.Column(db.Integer, nullable=False)
  1028. content = db.Column(db.Text, nullable=False)
  1029. word_count = db.Column(db.Integer, nullable=False)
  1030. # indexing fields
  1031. index_node_id = db.Column(db.String(255), nullable=True)
  1032. index_node_hash = db.Column(db.String(255), nullable=True)
  1033. type = db.Column(db.String(255), nullable=False, server_default=db.text("'automatic'::character varying"))
  1034. created_by = db.Column(StringUUID, nullable=False)
  1035. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1036. updated_by = db.Column(StringUUID, nullable=True)
  1037. updated_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1038. indexing_at = db.Column(db.DateTime, nullable=True)
  1039. completed_at = db.Column(db.DateTime, nullable=True)
  1040. error = db.Column(db.Text, nullable=True)
  1041. @property
  1042. def dataset(self):
  1043. return db.session.query(Dataset).filter(Dataset.id == self.dataset_id).first()
  1044. @property
  1045. def document(self):
  1046. return db.session.query(Document).filter(Document.id == self.document_id).first()
  1047. @property
  1048. def segment(self):
  1049. return db.session.query(DocumentSegment).filter(DocumentSegment.id == self.segment_id).first()
  1050. class AppDatasetJoin(db.Model): # type: ignore[name-defined]
  1051. __tablename__ = "app_dataset_joins"
  1052. __table_args__ = (
  1053. db.PrimaryKeyConstraint("id", name="app_dataset_join_pkey"),
  1054. db.Index("app_dataset_join_app_dataset_idx", "dataset_id", "app_id"),
  1055. )
  1056. id = db.Column(StringUUID, primary_key=True, nullable=False, server_default=db.text("uuid_generate_v4()"))
  1057. app_id = db.Column(StringUUID, nullable=False)
  1058. dataset_id = db.Column(StringUUID, nullable=False)
  1059. created_at = db.Column(db.DateTime, nullable=False, server_default=db.func.current_timestamp())
  1060. @property
  1061. def app(self):
  1062. return db.session.get(App, self.app_id)
  1063. class DatasetQuery(db.Model): # type: ignore[name-defined]
  1064. __tablename__ = "dataset_queries"
  1065. __table_args__ = (
  1066. db.PrimaryKeyConstraint("id", name="dataset_query_pkey"),
  1067. db.Index("dataset_query_dataset_id_idx", "dataset_id"),
  1068. )
  1069. id = db.Column(StringUUID, primary_key=True, nullable=False, server_default=db.text("uuid_generate_v4()"))
  1070. dataset_id = db.Column(StringUUID, nullable=False)
  1071. content = db.Column(db.Text, nullable=False)
  1072. source = db.Column(db.String(255), nullable=False)
  1073. source_app_id = db.Column(StringUUID, nullable=True)
  1074. created_by_role = db.Column(db.String, nullable=False)
  1075. created_by = db.Column(StringUUID, nullable=False)
  1076. created_at = db.Column(db.DateTime, nullable=False, server_default=db.func.current_timestamp())
  1077. class DatasetKeywordTable(db.Model): # type: ignore[name-defined]
  1078. __tablename__ = "dataset_keyword_tables"
  1079. __table_args__ = (
  1080. db.PrimaryKeyConstraint("id", name="dataset_keyword_table_pkey"),
  1081. db.Index("dataset_keyword_table_dataset_id_idx", "dataset_id"),
  1082. )
  1083. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  1084. dataset_id = db.Column(StringUUID, nullable=False, unique=True)
  1085. keyword_table = db.Column(db.Text, nullable=False)
  1086. data_source_type = db.Column(
  1087. db.String(255), nullable=False, server_default=db.text("'database'::character varying")
  1088. )
  1089. @property
  1090. def keyword_table_dict(self):
  1091. class SetDecoder(json.JSONDecoder):
  1092. def __init__(self, *args, **kwargs):
  1093. super().__init__(object_hook=self.object_hook, *args, **kwargs)
  1094. def object_hook(self, dct):
  1095. if isinstance(dct, dict):
  1096. for keyword, node_idxs in dct.items():
  1097. if isinstance(node_idxs, list):
  1098. dct[keyword] = set(node_idxs)
  1099. return dct
  1100. # get dataset
  1101. dataset = Dataset.query.filter_by(id=self.dataset_id).first()
  1102. if not dataset:
  1103. return None
  1104. if self.data_source_type == "database":
  1105. return json.loads(self.keyword_table, cls=SetDecoder) if self.keyword_table else None
  1106. else:
  1107. file_key = "keyword_files/" + dataset.tenant_id + "/" + self.dataset_id + ".txt"
  1108. try:
  1109. keyword_table_text = storage.load_once(file_key)
  1110. if keyword_table_text:
  1111. return json.loads(keyword_table_text.decode("utf-8"), cls=SetDecoder)
  1112. return None
  1113. except Exception as e:
  1114. logging.exception(f"Failed to load keyword table from file: {file_key}")
  1115. return None
  1116. class Embedding(db.Model): # type: ignore[name-defined]
  1117. __tablename__ = "embeddings"
  1118. __table_args__ = (
  1119. db.PrimaryKeyConstraint("id", name="embedding_pkey"),
  1120. db.UniqueConstraint("model_name", "hash", "provider_name", name="embedding_hash_idx"),
  1121. db.Index("created_at_idx", "created_at"),
  1122. )
  1123. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  1124. model_name = db.Column(
  1125. db.String(255), nullable=False, server_default=db.text("'text-embedding-ada-002'::character varying")
  1126. )
  1127. hash = db.Column(db.String(64), nullable=False)
  1128. embedding = db.Column(db.LargeBinary, nullable=False)
  1129. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1130. provider_name = db.Column(db.String(255), nullable=False, server_default=db.text("''::character varying"))
  1131. def set_embedding(self, embedding_data: list[float]):
  1132. self.embedding = pickle.dumps(embedding_data, protocol=pickle.HIGHEST_PROTOCOL)
  1133. def get_embedding(self) -> list[float]:
  1134. return cast(list[float], pickle.loads(self.embedding)) # noqa: S301
  1135. class DatasetCollectionBinding(db.Model): # type: ignore[name-defined]
  1136. __tablename__ = "dataset_collection_bindings"
  1137. __table_args__ = (
  1138. db.PrimaryKeyConstraint("id", name="dataset_collection_bindings_pkey"),
  1139. db.Index("provider_model_name_idx", "provider_name", "model_name"),
  1140. )
  1141. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  1142. provider_name = db.Column(db.String(255), nullable=False)
  1143. model_name = db.Column(db.String(255), nullable=False)
  1144. type = db.Column(db.String(40), server_default=db.text("'dataset'::character varying"), nullable=False)
  1145. collection_name = db.Column(db.String(64), nullable=False)
  1146. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1147. class TidbAuthBinding(db.Model): # type: ignore[name-defined]
  1148. __tablename__ = "tidb_auth_bindings"
  1149. __table_args__ = (
  1150. db.PrimaryKeyConstraint("id", name="tidb_auth_bindings_pkey"),
  1151. db.Index("tidb_auth_bindings_tenant_idx", "tenant_id"),
  1152. db.Index("tidb_auth_bindings_active_idx", "active"),
  1153. db.Index("tidb_auth_bindings_created_at_idx", "created_at"),
  1154. db.Index("tidb_auth_bindings_status_idx", "status"),
  1155. )
  1156. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  1157. tenant_id = db.Column(StringUUID, nullable=True)
  1158. cluster_id = db.Column(db.String(255), nullable=False)
  1159. cluster_name = db.Column(db.String(255), nullable=False)
  1160. active = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  1161. status = db.Column(db.String(255), nullable=False, server_default=db.text("CREATING"))
  1162. account = db.Column(db.String(255), nullable=False)
  1163. password = db.Column(db.String(255), nullable=False)
  1164. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1165. class Whitelist(db.Model): # type: ignore[name-defined]
  1166. __tablename__ = "whitelists"
  1167. __table_args__ = (
  1168. db.PrimaryKeyConstraint("id", name="whitelists_pkey"),
  1169. db.Index("whitelists_tenant_idx", "tenant_id"),
  1170. )
  1171. id = db.Column(StringUUID, primary_key=True, server_default=db.text("uuid_generate_v4()"))
  1172. tenant_id = db.Column(StringUUID, nullable=True)
  1173. category = db.Column(db.String(255), nullable=False)
  1174. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1175. class DatasetPermission(db.Model): # type: ignore[name-defined]
  1176. __tablename__ = "dataset_permissions"
  1177. __table_args__ = (
  1178. db.PrimaryKeyConstraint("id", name="dataset_permission_pkey"),
  1179. db.Index("idx_dataset_permissions_dataset_id", "dataset_id"),
  1180. db.Index("idx_dataset_permissions_account_id", "account_id"),
  1181. db.Index("idx_dataset_permissions_tenant_id", "tenant_id"),
  1182. )
  1183. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"), primary_key=True)
  1184. dataset_id = db.Column(StringUUID, nullable=False)
  1185. account_id = db.Column(StringUUID, nullable=False)
  1186. tenant_id = db.Column(StringUUID, nullable=False)
  1187. has_permission = db.Column(db.Boolean, nullable=False, server_default=db.text("true"))
  1188. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1189. class ExternalKnowledgeApis(db.Model): # type: ignore[name-defined]
  1190. __tablename__ = "external_knowledge_apis"
  1191. __table_args__ = (
  1192. db.PrimaryKeyConstraint("id", name="external_knowledge_apis_pkey"),
  1193. db.Index("external_knowledge_apis_tenant_idx", "tenant_id"),
  1194. db.Index("external_knowledge_apis_name_idx", "name"),
  1195. )
  1196. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  1197. name = db.Column(db.String(255), nullable=False)
  1198. description = db.Column(db.String(255), nullable=False)
  1199. tenant_id = db.Column(StringUUID, nullable=False)
  1200. settings = db.Column(db.Text, nullable=True)
  1201. created_by = db.Column(StringUUID, nullable=False)
  1202. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1203. updated_by = db.Column(StringUUID, nullable=True)
  1204. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1205. def to_dict(self):
  1206. return {
  1207. "id": self.id,
  1208. "tenant_id": self.tenant_id,
  1209. "name": self.name,
  1210. "description": self.description,
  1211. "settings": self.settings_dict,
  1212. "dataset_bindings": self.dataset_bindings,
  1213. "created_by": self.created_by,
  1214. "created_at": self.created_at.isoformat(),
  1215. }
  1216. @property
  1217. def settings_dict(self):
  1218. try:
  1219. return json.loads(self.settings) if self.settings else None
  1220. except JSONDecodeError:
  1221. return None
  1222. @property
  1223. def dataset_bindings(self):
  1224. external_knowledge_bindings = (
  1225. db.session.query(ExternalKnowledgeBindings)
  1226. .filter(ExternalKnowledgeBindings.external_knowledge_api_id == self.id)
  1227. .all()
  1228. )
  1229. dataset_ids = [binding.dataset_id for binding in external_knowledge_bindings]
  1230. datasets = db.session.query(Dataset).filter(Dataset.id.in_(dataset_ids)).all()
  1231. dataset_bindings = []
  1232. for dataset in datasets:
  1233. dataset_bindings.append({"id": dataset.id, "name": dataset.name})
  1234. return dataset_bindings
  1235. class ExternalKnowledgeBindings(db.Model): # type: ignore[name-defined]
  1236. __tablename__ = "external_knowledge_bindings"
  1237. __table_args__ = (
  1238. db.PrimaryKeyConstraint("id", name="external_knowledge_bindings_pkey"),
  1239. db.Index("external_knowledge_bindings_tenant_idx", "tenant_id"),
  1240. db.Index("external_knowledge_bindings_dataset_idx", "dataset_id"),
  1241. db.Index("external_knowledge_bindings_external_knowledge_idx", "external_knowledge_id"),
  1242. db.Index("external_knowledge_bindings_external_knowledge_api_idx", "external_knowledge_api_id"),
  1243. )
  1244. id = db.Column(StringUUID, nullable=False, server_default=db.text("uuid_generate_v4()"))
  1245. tenant_id = db.Column(StringUUID, nullable=False)
  1246. external_knowledge_api_id = db.Column(StringUUID, nullable=False)
  1247. dataset_id = db.Column(StringUUID, nullable=False)
  1248. external_knowledge_id = db.Column(db.Text, nullable=False)
  1249. created_by = db.Column(StringUUID, nullable=False)
  1250. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1251. updated_by = db.Column(StringUUID, nullable=True)
  1252. updated_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1253. class DatasetAutoDisableLog(db.Model): # type: ignore[name-defined]
  1254. __tablename__ = "dataset_auto_disable_logs"
  1255. __table_args__ = (
  1256. db.PrimaryKeyConstraint("id", name="dataset_auto_disable_log_pkey"),
  1257. db.Index("dataset_auto_disable_log_tenant_idx", "tenant_id"),
  1258. db.Index("dataset_auto_disable_log_dataset_idx", "dataset_id"),
  1259. db.Index("dataset_auto_disable_log_created_atx", "created_at"),
  1260. )
  1261. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  1262. tenant_id = db.Column(StringUUID, nullable=False)
  1263. dataset_id = db.Column(StringUUID, nullable=False)
  1264. document_id = db.Column(StringUUID, nullable=False)
  1265. notified = db.Column(db.Boolean, nullable=False, server_default=db.text("false"))
  1266. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1267. class RateLimitLog(db.Model): # type: ignore[name-defined]
  1268. __tablename__ = "rate_limit_logs"
  1269. __table_args__ = (
  1270. db.PrimaryKeyConstraint("id", name="rate_limit_log_pkey"),
  1271. db.Index("rate_limit_log_tenant_idx", "tenant_id"),
  1272. db.Index("rate_limit_log_operation_idx", "operation"),
  1273. )
  1274. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  1275. tenant_id = db.Column(StringUUID, nullable=False)
  1276. subscription_plan = db.Column(db.String(255), nullable=False)
  1277. operation = db.Column(db.String(255), nullable=False)
  1278. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1279. class DatasetMetadata(db.Model): # type: ignore[name-defined]
  1280. __tablename__ = "dataset_metadatas"
  1281. __table_args__ = (
  1282. db.PrimaryKeyConstraint("id", name="dataset_metadata_pkey"),
  1283. db.Index("dataset_metadata_tenant_idx", "tenant_id"),
  1284. db.Index("dataset_metadata_dataset_idx", "dataset_id"),
  1285. )
  1286. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  1287. tenant_id = db.Column(StringUUID, nullable=False)
  1288. dataset_id = db.Column(StringUUID, nullable=False)
  1289. type = db.Column(db.String(255), nullable=False)
  1290. name = db.Column(db.String(255), nullable=False)
  1291. created_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1292. updated_at = db.Column(db.DateTime, nullable=False, server_default=db.text("CURRENT_TIMESTAMP(0)"))
  1293. created_by = db.Column(StringUUID, nullable=False)
  1294. updated_by = db.Column(StringUUID, nullable=True)
  1295. class DatasetMetadataBinding(db.Model): # type: ignore[name-defined]
  1296. __tablename__ = "dataset_metadata_bindings"
  1297. __table_args__ = (
  1298. db.PrimaryKeyConstraint("id", name="dataset_metadata_binding_pkey"),
  1299. db.Index("dataset_metadata_binding_tenant_idx", "tenant_id"),
  1300. db.Index("dataset_metadata_binding_dataset_idx", "dataset_id"),
  1301. db.Index("dataset_metadata_binding_metadata_idx", "metadata_id"),
  1302. db.Index("dataset_metadata_binding_document_idx", "document_id"),
  1303. )
  1304. id = db.Column(StringUUID, server_default=db.text("uuid_generate_v4()"))
  1305. tenant_id = db.Column(StringUUID, nullable=False)
  1306. dataset_id = db.Column(StringUUID, nullable=False)
  1307. metadata_id = db.Column(StringUUID, nullable=False)
  1308. document_id = db.Column(StringUUID, nullable=False)
  1309. created_at = db.Column(db.DateTime, nullable=False, server_default=func.current_timestamp())
  1310. created_by = db.Column(StringUUID, nullable=False)