Existe um sistema operativo separado no Pod?
Python
O que é uma partição (partition) no Kafka? O que é um grupo de consumidores?
Quais são os tipos e classes de testes de software existentes?
Olhe para a função count_pairs. Qual é a sua complexidade? Escreva uma versão mais eficiente.
Fale sobre o padrão Saga. Como o implementaram na sua empresa? Como notificavam os serviços sobre o rollback?
Escreva um Dockerfile para uma aplicação Python que faça o seguinte: - Use a última imagem do Python - Define o diretório de trabalho para /app - Copie o conteúdo do diretório atual para o container - Instale as dependências listadas em requirements.txt - Exponha a porta 8000 - Execute a aplicação usando o comando: python app.py
Por que é necessária a encapsulação? Quais são os riscos de acessar diretamente os dados do objeto?
O que é encapsulação? Quais são as características do ponto de vista do Python?
Como criar uma estrutura de dados na qual não se possa inserir ou alterar valores, mas se possa obter por chave?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Análise e armazenamento no banco de dados leva cerca de 10 segundos parse_text_and_save_to_postgres(text_data)
# Quanto tempo leva para executar asyncio.run(main())?
Como lidar com uma função bloqueante de uma biblioteca antiga para não bloquear o loop de eventos?
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"}
Qual é o objeto retornado por uma função com `yield`, e qual anotação de tipo de retorno é adequada aqui em vez de `list[str]`?
Conte-nos um pouco sobre você e sua experiência técnica.
Qual é o padrão chamado em que `Engine` é criado uma vez para a aplicação e gerencia um pool de conexões compartilhado?
O que acontece se o pod do consumidor Kafka falhar durante o processamento da mensagem antes de confirmar o deslocamento?
O que é uma API REST?
Quais são as vantagens de um monolito modular em comparação com os microserviços nesta situação?