Analise de dados Near Real Time - Python + Kafka + Streamlit + Postgres

Рет қаралды 980

Wallace Camargo

Күн бұрын

Пікірлер: 12

@silvapereira92 9 ай бұрын

Muito bom Wallace, seria possível adicionar no script pra gerar votos em um determinado período de forma automática?

@wallacecamargo1043 9 ай бұрын

é possível sim!! basta criar um agendamento pela crontab, airflow ou no lugar de sua preferência.

@matheusrodrigues2644 10 ай бұрын

Projeto top uma duvida o postgres seu está em modo logical do wal_level porque vi que tu usou o kafka confluence né como tu fez essa conexão com o postgres? E mais uma vez parabéns pelo video

@wallacecamargo1043 10 ай бұрын

Muito obrigado pelo feedback meu amigo!!! A conexão com o postgres foi via psycopg2, conforme script abaixo: if __name__ == "__main__": conn = psycopg2.connect("host=172.31.156.222 port=5433 dbname=Voting user=postgres password=postgres") cur = conn.cursor() producer = SerializingProducer({'bootstrap.servers': 'localhost:9092', }) create_tables(conn, cur) for i in range(50): voter_data = generate_voter_data() insert_voters(conn, cur, voter_data) producer.produce( voters_topic, key=voter_data["voter_id"], value=json.dumps(voter_data), on_delivery=delivery_report ) print('Produced voter {}, data: {}'.format(i, voter_data)) producer.flush()

@pauloricardoferreira3142 10 ай бұрын

Sensacional. Poderia aumentar o áudio, aqui pra mim saiu um pouco baixo. Att

@wallacecamargo1043 10 ай бұрын

Obrigado pelo feedback meu amigo!!! não sei o que tem acontecido com o áudio, mas realmente sempre tem ficado baixo. Grato pelo feedback, vou tentar melhorar nos próximos!!! grande abraço e sucesso nos projetos!!! TMJ!!!

@magnumcosta 10 ай бұрын

O áudio ficou bom aqui

@wallacecamargo1043 10 ай бұрын

@@magnumcosta grato pelo feedback meu amigo!!!