from pymongo import MongoClient

def connect_to_mongo():
    """Подключение к MongoDB"""
    client = MongoClient("mongodb://localhost:27017/")
    db = client["Food"]
    return db["Test"]


def import_json_in_mongo(recipe_data):
    collection = connect_to_mongo()

    print(recipe_data)

    try:
        collection.replace_one({"_id": recipe_data["_id"]}, recipe_data, upsert=True)
        print(f"Рецепт '{recipe_data.get('recipe_name', recipe_data['_id'])}' успешно сохранён.")
    except Exception as e:
        print(f"Ошибка при сохранении рецепта {recipe_data.get('_id')}: {e}")