The DataOps Blog
Where Change Is Welcome
Solving Data Quality in Streaming Data Flows
Vinu Kumar is Chief Technologist at HorizonX, based in Sydney, Australia. Vinu helps businesses in unifying data, focusing on a centralized data architecture. In this guest post, reposted from the original here, he explains how to automate data quality using open source tools such as StreamSets Data Collector, Apache Griffin and Apache Kafka. "Data is the new oil. It’s valuable, but if unrefined…
Scaling Data Collectors on Azure Kubernetes Service
In this blog post, I will present a step-by-step guide on how to scale Data Collector instances on Azure Kubernetes Service (AKS) using provisioning agents—which help automate upgrading and scaling resources on-demand, without having to stop execution of pipeline jobs. AKS removes the complexity of implementing, installing, and maintaining Kubernetes in Azure and you only pay for the resources you…
Execute Machine Learning Jobs in Microsoft Azure Databricks from StreamSets
In my previous blog post, I demonstrated how to achieve low-latency inference using Databricks ML models in StreamSets. Now let's say you have a dataflow pipeline that is ingesting data, enriching it, performing transformations, and based on certain condition(s), you'd like to (re)train the Databricks ML model. For instance, using different value for hyperparameter n_estimators ("number of trees" in the…
Creating Dataflow Pipelines with Amazon Kinesis
Although the recent public preview of Amazon Managed Streaming for Kafka (MSK) certainly made headlines, Kinesis remains Amazon's supported, production, real-time streaming service. In this blog post, I'll show you how to get started using StreamSets Data Collector to build dataflow pipelines to send data to and receive data from Amazon Kinesis Data Streams. Getting Started with Amazon Kinesis Data Streams A…
Ingesting Data from Relational Databases to Cassandra with StreamSets
This post is summarized content from a full tutorial at https://academy.datastax.com/content/ingesting-data-relational-databases-cassandra-streamsets How do you ingest from an existing relational database (RDBMS) to an Apache Cassandra or DataStax Enterprise cluster? What about a one-time batch loading of historical data vs. streaming changes? I know what some of you are thinking, write and deploy some…
