A simple transfer data between NiFi and CQL solution (support Apache Cassandra, ScyllaDB, AstraDB, etc.).

Building data processing pipelines for documents processing with NLP using Apache NiFi and related services

A reporting task in Nifi which is capable of sending monitoring statistics as prometheus metrics to a prometheus pushgateway.

Deploy a secured, clustered, auto-scaling NiFi service in AWS.

Open Source Computer Vision with TensorFlow, MiniFi, Apache NiFi, OpenCV, Apache Tika and Python For processing images from IoT devices like Raspberry Pis, NVidia Jetson TX1, NanoPi Duos and more which are equipped with attached cameras or external USB webcams, we use Python to interface via OpenCV and PiCamera. From there we run image processing at the edge on these IoT device using OpenCV and TensorFlow to determine attributes and image analytics. A pache MiniFi coordinates running these Python scripts and decides when and what to send from that analysis and the image to a remote Apache NiFi server for additional processing. At the Apache NiFi cluster in the cluster it routes the images to one processing path and the JSON encoded metadata to another flow. The JSON data (with it's schema referenced from a central Schema Registry) is routed and routed using Record Processing and SQL, this data in enriched and augment before conversion to AVRO to be send via Apache Kafka to SAM. Streaming Analytics Manager then does deeper processing on this stream and others including weather and twitter to determine what should be done on this data. References https://community.hortonworks.com/articles/103863/using-an-asus-tinkerboard-with-tensorflow-and-pyth.html https://community.hortonworks.com/articles/118132/minifi-capturing-converting-tensorflow-inception-t.html https://github.com/tspannhw/rpi-noir-screen https://community.hortonworks.com/articles/77988/ingest-remote-camera-images-from-raspberry-pi-via.html https://community.hortonworks.com/articles/107379/minifi-for-image-capture-and-ingestion-from-raspbe.html https://community.hortonworks.com/articles/58265/analyzing-images-in-hdf-20-using-tensorflow.html

Example Tensorflow Processor using Java API for Apache NiFi 1.2 - 1.9.1+

Drools processor for Apache NiFi

An Apache NiFi processor to encode and decode data using Google Protocol Buffer schemas.

📚🧪 Traffic Sentinel is a learning-focused POC that explores a scalable IoT architecture using Fog nodes and Apache Flink to process 📷 IP camera streams, powered by YOLO for intelligent 🚗 traffic monitoring on highways. 🛣️

OPC UA controller service and processors for Apache NiFi

No description provided.

A Smart Traffic Management System for Ho Chi Minh City, Vietnam leveraging batch and real-time data processing, intuitive dashboards, and monitoring tools to optimize traffic flow, enhance safety, and support sustainable urban mobility through advanced analytics and user-friendly applications.

Template for creating batch based ETL workflow for datawarehouses

Simulation of job offers and CVs with real-time processing, classification, and analytics using Kafka, Ray, Spark, and Databricks. Includes a Flask-based recommendation system and Tableau visualizations.

Stocks -> NiFi -> Kafka -> Profit

Apache NiFi 1.5/1.6/1.9.2+ Processor to produce DDL

A utility to help coordinate upgrading the same process group on multiple Apache NiFi cluster instances.

Cloudera Flow Management Workshop with Apache NiFi

Verteego Data Suite

Clean up attribute names for Apache NiFi to send to Apache Avro

Neste projeto, mergulho no universo do Apache Nifi, explorando como consumir e salvar dados de uma API diretamente em um banco de dados.

Lets create Agile Architecture diagrams using dot language + graphviz + aws icons + git

This project builds a scalable log analytics pipeline use Lambda architecture for real-time and batch processing of NASA server logs.

Examples for Apache Flume to Apache NiFi

Apache NiFi - DeepLearning4J Example Processor for VGG16 based https://github.com/SkymindIO/Demos-for-sales-marketting

Projeto de Alertas Cripto com Análise de Preços em Tempo Real com Apache Nifi e n8n

Apache Deep Learning 201 with Apache MXNet

.NET Core Client for Apache NiFi using swagger-cogeden

An introduction to using Kylo, an open source data lake builder from Teradata

LDAP Configuration for running a secure NiFi docker container