რა არის partition Kafka-ში? რა არის consumer group?
Python
როგორია პროგრამული უზრუნველყოფის ტესტირების ტიპები და კლასი?
FastAPI საშუალებას აძლევს ფუნქციების როგორც ასინქრონული, ასევე სინქრონული განხორციელება — როგორ ახდენს ეს გავლენას ქცევაზე? როგორ პარალელურად განახორციელოთ მოთხოვნები async ფუნქციაში?
გაამოწმეთ count_pairs ფუნქცია. რა არის მისი სირთულე? დაწერეთ უფრო ეფექტიანი ვერსია.
Saga ნიმუშის შესახებ ისაუბრეთ. როგორ განახორციელეთ თქვენი სისტემაში? როგორ აცნობეთ სერვისებს დაბრუნების შესახებ?
დაწერეთ Dockerfile Python აპლიკაციისთვის, რომელიც აკეთებს შემდეგს: - იყენებს უახლეს Python-ის იმიჯს - ადგენს სამუშაო დირექტორიას /app - კოპირებს მიმდინარე დირექტორიის შიგთავსს კონტეინერში - ინსტალირებს dependencies, რომლებიც ჩამოთვლილია requirements.txt-ში - გამოდის პორტ 8000 - ამუშავებს აპლიკაციას შემდეგი ბრძანებით: python app.py
რატომ არის საჭირო ინკაპსულაცია? რა რისკები არსებობს ობიექტის მონაცემებს პირდაპირ მიმართვისას?
ინკაპსულაცია რა არის? რა თვისებები აქვს Python-ის თვალსაზრისით?
როგორ შევქმნათ მონაცემთა სტრუქტურა, რომელშიც მნიშვნელობების ჩაწერა ან შეცვლა შეუძლებელია, მაგრამ გასაღებით მიღება შესაძლებელია?
# რამდენი დრო სჭირდება asyncio.run(main())-ის შესრულებას?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # ტექსტების ანალიზი და შენახვა მონაცემთა ბაზაში დაახლოებით 10 წამი გრძელდება parse_text_and_save_to_postgres(text_data)
როგორ უნდა მოვიქცეთ ბლოკირებადი ფუნქციისთან ერთად ძველი ბიბლიოთეკიდან, რათა არ ბლოკავდეს მოვლენის ციკლს?
async def get_user(user_id: int, db: AsyncSession): try: user = await db.get(User, user_id) return user finally: await db.close() return None a = await get_user(15, db) # a?
app = FastAPI() def get_db(): db = SessionLocal() try: yield db finally: db.close() def heavy_text_parser(file_id: int, db: Session): # 5 мүнөттүк файлдын анализи parse_and_save(file_id, db) @app.post("/upload") async def upload_file( background_tasks: BackgroundTasks, db: Session = Depends(get_db) ): file_id = save_file_to_db(db) db.commit() background_tasks.add_task(heavy_text_parser, file_id, db) return {"status": "parsing started"}
რა არის ობიექტი, რომელიც ფუნქციამ აბრუნებს `yield`-ით, და რა დაბრუნების ტიპის ანოტაცია არის აქ შესაბამისი `list[str]`-ის ნაცვლად?
მოგვითხრეთ ცოტა საკუთარ შესახებ და თქვენი ტექნიკური გამოცდილების შესახებ.
რა სახელწოდებაა ნიმუში, სადაც `Engine` ერთჯერადად ქმნის პროგრამისთვის და მართავს საერთო კავშირის პულს?
რა ხდება, თუ Kafka-ის მომხმარებლის პოდი დაშლის შეტყობინების დამუშავების დროს, ოffset-ის დადასტურებამდე?
რა არის REST API?
რა სარგებელი აქვს მოდულურ მონოლიტს ასეთ სიტუაციაში, შედარებით მიკროწესევებთან?