File size: 915 Bytes
102dd4f | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 | # يرسل بيانات الرحلات الحية إلى جداول المتجهات في Supabase
import asyncio
import os
import sys
ROOT_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
if ROOT_DIR not in sys.path:
sys.path.insert(0, ROOT_DIR)
from app.config import get_settings
from app.database.supabase import SupabaseRepository, create_supabase_client
from app.services.admin_service import AdminService
from app.services.embedding_service import JinaEmbeddingService
async def main() -> None:
settings = get_settings()
repository = SupabaseRepository(await create_supabase_client(settings))
service = AdminService(
repository=repository,
embeddings=JinaEmbeddingService(settings),
settings=settings,
)
indexed = await service.sync_trips()
print(f"Indexed {indexed} active trips")
if __name__ == "__main__":
asyncio.run(main())
|