add data viewer
Browse files- app/supabase_db.py +6 -6
app/supabase_db.py
CHANGED
|
@@ -199,16 +199,16 @@ class SupabaseClient:
|
|
| 199 |
|
| 200 |
all_chunks = []
|
| 201 |
page_size = 1000
|
| 202 |
-
|
| 203 |
|
| 204 |
while True:
|
| 205 |
-
#
|
| 206 |
-
response = self.client.table('document_chunks').select('*').
|
| 207 |
|
| 208 |
-
logger.info(f"[SUPABASE] Fetched page:
|
| 209 |
|
| 210 |
if not response.data:
|
| 211 |
-
logger.info(f"[SUPABASE] No more data at
|
| 212 |
break
|
| 213 |
|
| 214 |
all_chunks.extend(response.data)
|
|
@@ -218,7 +218,7 @@ class SupabaseClient:
|
|
| 218 |
logger.info(f"[SUPABASE] Last page with {len(response.data)} records")
|
| 219 |
break
|
| 220 |
|
| 221 |
-
|
| 222 |
|
| 223 |
logger.info(f"[SUPABASE] Successfully fetched {len(all_chunks)} document chunks (expected: {total_count})")
|
| 224 |
return all_chunks
|
|
|
|
| 199 |
|
| 200 |
all_chunks = []
|
| 201 |
page_size = 1000
|
| 202 |
+
start = 0
|
| 203 |
|
| 204 |
while True:
|
| 205 |
+
# Sử dụng .range() với syntax đúng
|
| 206 |
+
response = self.client.table('document_chunks').select('*').range(start, start + page_size - 1).execute()
|
| 207 |
|
| 208 |
+
logger.info(f"[SUPABASE] Fetched page: start={start}, end={start + page_size - 1}, count={len(response.data) if response.data else 0}")
|
| 209 |
|
| 210 |
if not response.data:
|
| 211 |
+
logger.info(f"[SUPABASE] No more data at start {start}")
|
| 212 |
break
|
| 213 |
|
| 214 |
all_chunks.extend(response.data)
|
|
|
|
| 218 |
logger.info(f"[SUPABASE] Last page with {len(response.data)} records")
|
| 219 |
break
|
| 220 |
|
| 221 |
+
start += page_size
|
| 222 |
|
| 223 |
logger.info(f"[SUPABASE] Successfully fetched {len(all_chunks)} document chunks (expected: {total_count})")
|
| 224 |
return all_chunks
|