Pipeline de dados clickstream totalmente serverless e orientado a eventos na AWS que ingere, transforma e armazena eventos em Parquet usando API Gateway, Kinesis, Firehose, Lambda e Athena, com IaC pronto para produção via AWS SAM.
Código aberto. Novas possibilidades.
Descubra projetos open source de qualidade, envie projetos anonimamente e reivindique e edite seu próprio projeto.
Um pouco de curiosidade. Um mundo de código aberto.
THE FIRST COLLECTIONAllSource é um armazenamento de eventos nativo de IA construído em Rust, com ingestão de alta taxa de transferência, leitura de baixa latência e integração nativa MCP para agentes de IA. Suporta sourcing de eventos durável sem Postgres, inclui um mecanismo de memória de agente e oferece edições comunitária e empresarial.
Biblioteca Go que oferece blocos de construção limitados para produtor, consumidor, replay, inspeção e transações do Apache Kafka, encapsulando o franz-go sem ocultar resultados de entrega ou políticas de tópico.
Lexos é um mecanismo de processamento de documentos com IA orientado a eventos, combinando um gateway Go, workers Python, filas Redis e modelos auto-hospedados para RAG offline, sumarização e transcrição de fala.
Watermill é uma biblioteca Go para construir aplicações orientadas a eventos com fluxos de mensagens. Ela oferece uma interface simples para mensageria pub/sub, com suporte a Kafka, RabbitMQ, NATS, Redis, SQL e outros.
Um framework opinionated baseado em Node.js e TypeScript que trata o AWS Lambda como cidadão de primeira classe, oferecendo suporte a DDD, Unit of Work, RFC 7807, OpenTelemetry e faturamento SaaS.
PAPAI é um agente pessoal de IA proativo para gerenciamento de tarefas em linguagem natural via Telegram, Mattermost, Discord e Kontur Talk, integrando-se a Kaneo e YouTrack.
Hatchet é um mecanismo de orquestração open-source para tarefas em segundo plano, agentes de IA e workflows duradouros. Suporta Python, TypeScript, Go e Ruby via auto-hospedagem ou Hatchet Cloud. Oferece retry de tarefas, jobs cron, DAGs, monitoramento em tempo real e multi-tenancy.