This commit is contained in:
parent
3a46e78349
commit
ec96fc3862
@ -1,6 +1,5 @@
|
|||||||
import os
|
import os
|
||||||
import io
|
import io
|
||||||
import asyncio
|
|
||||||
import traceback
|
import traceback
|
||||||
from telegram import Update
|
from telegram import Update
|
||||||
from telegram.ext import filters, ApplicationBuilder, MessageHandler, CommandHandler, ContextTypes
|
from telegram.ext import filters, ApplicationBuilder, MessageHandler, CommandHandler, ContextTypes
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
from django.core.management import BaseCommand
|
from django.core.management import BaseCommand
|
||||||
import clickhouse_connect
|
import clickhouse_connect
|
||||||
from vacancies.main.vector_store import add_vectors, extract_features, client as qdrant
|
from vacancies.main.vector_store import add_vectors, extract_features, qdrant_client
|
||||||
from vacancies.conf.settings import CLICKHOUSE_HOST, CLICKHOUSE_PORT
|
from vacancies.conf.settings import CLICKHOUSE_HOST, CLICKHOUSE_PORT
|
||||||
|
|
||||||
clickhouse_client = clickhouse_connect.create_client(host=CLICKHOUSE_HOST, port=CLICKHOUSE_PORT)
|
clickhouse_client = clickhouse_connect.create_client(host=CLICKHOUSE_HOST, port=CLICKHOUSE_PORT)
|
||||||
@ -29,7 +29,7 @@ class Command(BaseCommand):
|
|||||||
next_page_offset = 0
|
next_page_offset = 0
|
||||||
exist_points_ids = [-1]
|
exist_points_ids = [-1]
|
||||||
while next_page_offset is not None:
|
while next_page_offset is not None:
|
||||||
response = qdrant.scroll(
|
response = qdrant_client.scroll(
|
||||||
collection_name="vacancies",
|
collection_name="vacancies",
|
||||||
limit=100_000,
|
limit=100_000,
|
||||||
offset=next_page_offset,
|
offset=next_page_offset,
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user