mirror of
https://git.mirrors.martin98.com/https://github.com/infiniflow/ragflow.git
synced 2025-08-13 11:49:05 +08:00
fix minio helth bug (#850)
### What problem does this PR solve? #643 ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
parent
c27c02ea67
commit
a12fcf9156
@ -7,7 +7,7 @@ from rag.nlp import find_codec
|
|||||||
|
|
||||||
|
|
||||||
class RAGFlowExcelParser:
|
class RAGFlowExcelParser:
|
||||||
def html(self, fnm,chunk_rows=256):
|
def html(self, fnm, chunk_rows=256):
|
||||||
if isinstance(fnm, str):
|
if isinstance(fnm, str):
|
||||||
wb = load_workbook(fnm)
|
wb = load_workbook(fnm)
|
||||||
else:
|
else:
|
||||||
|
@ -78,7 +78,7 @@ def chunk(filename, binary=None, from_page=0, to_page=100000,
|
|||||||
elif re.search(r"\.xlsx?$", filename, re.IGNORECASE):
|
elif re.search(r"\.xlsx?$", filename, re.IGNORECASE):
|
||||||
callback(0.1, "Start to parse.")
|
callback(0.1, "Start to parse.")
|
||||||
excel_parser = ExcelParser()
|
excel_parser = ExcelParser()
|
||||||
sections = excel_parser.html(binary , 10000000)
|
sections = excel_parser.html(binary, 1000000000)
|
||||||
|
|
||||||
elif re.search(r"\.txt$", filename, re.IGNORECASE):
|
elif re.search(r"\.txt$", filename, re.IGNORECASE):
|
||||||
callback(0.1, "Start to parse.")
|
callback(0.1, "Start to parse.")
|
||||||
|
@ -35,7 +35,7 @@ class RAGFlowMinio(object):
|
|||||||
self.conn = None
|
self.conn = None
|
||||||
|
|
||||||
def health(self):
|
def health(self):
|
||||||
bucket, fnm, binary = "_t@@@1", "_t@@@1", b"_t@@@1"
|
bucket, fnm, binary = "txtxtxtxt1", "txtxtxtxt1", b"_t@@@1"
|
||||||
if not self.conn.bucket_exists(bucket):
|
if not self.conn.bucket_exists(bucket):
|
||||||
self.conn.make_bucket(bucket)
|
self.conn.make_bucket(bucket)
|
||||||
r = self.conn.put_object(bucket, fnm,
|
r = self.conn.put_object(bucket, fnm,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user