Skip to content
Enterprise Integrator Documentation Tutorials Overview
7.0.0
  • Show all
Streaming Integrator
To use the latest EI version,
see the latest documentation.
Type to start searching
    • Get Started
    • Learn
    • Setup and Install
    • Develop
    • Observability
    • Connectors
    • References
    
    Report Issues
    wso2/docs-ei
    • Home
      • Introduction
      • Quick Start Guide
        • Streaming Integration Overview
        • Step 1: Download and Install Streaming Integrator
        • Step 2: Create the Siddhi Application
        • Step 3: Test the Siddhi Application
        • Step 4: Deploy the Siddhi Application
        • Extend WSO2 SI
      • Running the Streaming Integrator with Micro Integrator
      • Architecture
      • Key Concepts
        • Use Cases
        • Consuming Data
        • Transforming Data
        • Enriching Data
        • Cleansing Data
        • Correlating Data
        • Summarizing Data
        • Integrating Stores
        • Publishing Data
        • Triggering Integration Flows
        • Tutorials Overview
        • Performing Real-time ETL with MySQL
        • Performing Real-time ETL with Files
        • Working with Kafka
        • Working with Business Rules
        • Exposing Processed Data as API
        • Triggering Integrations via MI
        • Running SI with Docker and Kubernetes
          • Receiving JSON Events via TCP
          • Publishing Events to a Google Pub/Sub Topic
          • Publishing and Receiving CSV Events via Files
          • Capturing MySQL Inserts via CDC
          • Receiving Messages from a Google Pub/Sub Topic
          • Receiving XML events via MQTT
          • Receiving Binary Events via TCP
          • Receiving Binary Events via Kafka
          • Receiving XML Events via HTTP
          • Working with an influxDB Store
          • Capturing MySQL Inserts and Updates via CDC Polling Mode
          • Retrieving Historical Tweets for a Given Time Period
          • Publishing HTTP Events to an OAuth-protected Endpoint while Using a Refresh Token Grant Type
          • Publishing HTTP Events via an OAuth-protected Endpoint
          • Receiving Events via Simulator and Persisting in SOLR Store
          • Receiving Events via HTTP Transport
          • Receiving Events via File
          • Receiving XML Events via Email
          • Receiving JSON Events via RabbitMQ
          • Receive Events via Simulator and Persist in Cassandra Store
          • Publishing HTTP Events to to an OAuth-protected Endpoint
          • Publishing HTTP Events to to an OAuth-protected Endpoint without an Access Token
          • Receiving ER7 Events via HL7
          • Preprocessing Data Received via TCP
          • Publishing ER7 Events via HL7
          • Receiving Data via TCP and Preprocessing
          • Receiving and Publishing Events in Custom CSV Format
          • Sending Custom JSON Events via HTTP
          • Publishing Text Events via Email
          • Receiving Custom Text Events via Kafka
          • Using Javascript Functions in Siddhi Applications
          • Publishing Custom Avro Events via Kafka
          • Receiving Custom XML Messages via HL7
          • Receiving Custom Text Events via TCP
          • Identifying Sub-sequences in Input Sequences
          • Publishing XML messages via HL7
          • Publishing JSON Events via Kafka
          • Publishing JSON Events to Files
          • Receiving Custom XML Events via HTTP
          • Publishing XML Events via RabbitMQ
          • Rounding up Amounts via the Math Function
          • Receiving Text Events via TCP
          • Publishing Emails in XML Format
          • Converting String Values to Lowercase
          • Text Mapping with In-memory Transport
          • Receiving JSON Events via HTTP
          • Consuming Events from a Kafka Topic and Publishing to Another Kafka Topic
          • Publishing Custom XML Events via HTTP
          • Sending Custom Keyvalue Events via SNMP
          • Publishing JSON Events via TCP
          • Publishing HTTP Events to an OAuth-protected Endpoint
          • Inserting and Accessing Data in a Map
          • Publishing XML Events via JMS
          • Receiving JSON Events via JMS
          • Receiving Custom JSON Events via HTTP
          • Counting the Frequency of Values with BottomK
          • Extracting Values from a String
          • Joining Streaming Data with Stored Data in RDBMS
          • Using Javascript Functions in Siddhi Applications
          • Receiving Events via Simulator and Persisting in a Store
          • Publishing HTTP Requests, Receiving Responses, and Processing Them
          • Converting Units
          • Calculating the Sentiment Value for a Given String
          • Processing Geo Data
          • Performing Streaming Learning Using a Clustree Model
          • Receiving XML Events via Websocket
          • Preprocessing Data Received via TCP
          • Receiving Data via TCP and Preprocessing
          • Publishing Text Events via Email
          • Calculating Aggregations Over Time
          • Calculating the Number of Distinct Events without a Siddhi Window
          • Calculating the Number of Distinct Events within a Siddhi Window
          • Receiving Events via HTTP Transport
          • Aggregating Data Incrementally
          • Receiving Events and Persisting Them in Redis Store
          • Receiving Events and Persisting in MongoDB Store
          • Making Predictions via PMML Model
          • Making Predictions via a Regressor Model
          • Extracting Values from a String
          • Performing Regression Tasks via an Imported Tensorflow Model
          • Calculating the Sentiment Value for a Given String
          • Publishing XML Events via MQTT
          • Identifying Event Patterns Based On Order of Event Arrival
          • Using StreamingML Kmeans for Clustering
          • Receiving Prometheus Metrics
          • Making Predictions via Hoeffding Classifier Model
          • Receiving Custom Key Value Events via SNMP
          • Receiving Key Value Events via JMS
          • Consuming Messages from IBM Message Queues
          • Receiving Email Alerts
          • Making Predictions via a Streaming Perceptron Model
          • Calculating the Distance Between Two Locations
          • Publishing Text Events via TCP
          • Receiving ER7 Events via HL7
          • Publishing Events to a Google Pub/Sub Topic
          • Publishing Binary Events via TCP
          • Publishing XML Events via WebSocket
          • Publishing Consumed Events to Prometheus Metrics and Exposing then via HTTP
          • Working with an influxDB Store
          • Publishing Binary Events via Kafka
          • Publishing Key-value events via JMS
          • Publishing XML Events via HTTP
          • Publishing HTTP Events to an OAuth-protected Endpoint while Using a Refresh Token Grant Type
          • Publishing HTTP Events via an OAuth-protected Endpoint
          • Receiving Events via Simulator and Persisting in SOLR Store
          • Publishing JSON Events via HTTP
          • Receiving Events via Simulator and Persisting in RDBMS Store
          • Receive Events via Simulator and Persist in Cassandra Store
          • Publishing Avro Events via Kafka
          • Publishing Aggregated Events to the Amazon AWS S3 Bucket
          • Publishing Events to a GCS Bucket
        • Install in a VM
        • Installing in Docker
        • Installing in Kubernetes
        • Upgrading WSO2 Enterprise Integrator
        • Single Deployment
        • Minimum HA Cluster
        • Active-Active Cluster
        • Scalable Cluster
        • Minimum HA Cluster in AWS ECS
        • Production Checklist
        • Configuring Datasources
        • Configuring Business Rules Deployment
        • General Data Protection Regulations
        • Working with Keystores
        • Supporting Different Transports
        • User Management
        • Configuring State Persistence
        • Configuring Cluster Coordination
        • Protecting Sensitive Data via the Secure Vault
        • Adding Third Party Non OSGi Library
        • Configuring Default Ports
        • Changing the Host Name and Context Path of Web UI Applications
      • Developing Streaming Integrator Solutions
        • Streaming Integrator Tooling Overview
        • Working with the Design View
      • Creating Siddhi Applications
      • Installing Siddhi Extensions
      • Testing Siddhi Applications
      • Deploying Siddhi Applications
      • Exporting Siddhi Applications
      • Monitoring the Streaming Integrator
      • Streaming Integrator Connectors Overview
      • Downloading and Installing Siddhi Connectors
      • Writing Custom Siddhi Extensions
      • Configuring System Parameters for Siddhi Extensions
      • Environment Compatibility
        • REST API Guide Overview
        • Siddhi Application Management APIs
        • Event Simulation APIs
        • Permission APIs
        • Business Rules APIs
        • Store APIs
        • Healthcheck APIs
        • HTTP Status Codes
      • Performance Analysis Results
    

    Tutorials Overview¶

    The following table lists the tutorials available for different user scenarios.

    User Scenario Tutorials
    Performing ETL - Performing Real-time ETL with Files
    - Performing Real-time ETL with MySQL
    Receiving and Publishing Data Working with Kafka
    Working with API Exposing Processed Data as API
    Working with the Micro Integrator Triggering Integration Flows via MI
    Working in Containerized Environments Running the Streaming Integrator in Containerized Environments
    Top
    Previous Triggering Integration Flows
    Next Performing Real-time ETL with MySQL
    WSO2 Enterprise Integrator - Documentation
    Copyright © WSO2 Inc. 2015-2021
    Content licensed under CC By 4.0. | Sample code licensed under Apache 2.0.