Блог

Я пытаюсь создать серверную службу (FastAPI), которая подключена к Firebase, используя вспомогательную библиотеку Pyrebase (как предложено в документации Firebase). База данных Firebase в реальном времени имеет структуру:

 "myproject_db" : {
        "movies":
            "key1": {
                "movie_id": 33
                "other_id": 44
            },
        "ratings":
            "key1": {
                "user_id" : 1
                "rating" : 5
                "movie_id" : 33
            },
    }
 

База данных фильмов и рейтингов содержит более 10 000 полей.

Теперь мой метод / getRatedMovies для конкретного пользователя описан ниже. Несмотря на то, что это работает, для завершения требуется более 30 секунд. Основная причина — повторение фильмов. Кажется, что каждый раз, когда мне нужно найти конкретный фильм, мне нужно просмотреть всю таблицу. Есть ли альтернативное решение, которого мне не хватает? Спасибо.

 @app.get("/getRatedMovies")
async def ratedMovies():
    try:
        ratings = db.child("ratings").order_by_child("user_id").equal_to(username).get()

        restructuredMovies: List[Movie] = []
        for rating in ratings.each():
            movieid: int = rating.val()["movie_id"]
            movies = db.child("movies").order_by_child("movie_id").equal_to(movie_id).get()
            for movie in movies:
                movieid: int = movie.val()['movie_id']
                other_id: Optional[str] = movie.val()["other_id"]
                restructuredMovie: Movie = Movie(title = movie.val()["title"], movieid = movieid, other_id = other_id)
                restructuredMovies.append(restructuredMovie)
        return {"Movies": restructuredMovies}
    except Exception as error:
        return {"error": "Something went wrong."}