Example: Using the AsapSource Component

Associate the AsapSource (reader) component with the FileSink (writer) component. AsapSource reads records from Event Stream Processor and passes those to FileSink, which then writes those records to the out.txt file.

  1. Start Event Stream Processor.
    Operating System Step
    UNIX Open a terminal window:
    1. Start the example cluster:

      start_server_cluster.sh

    2. Start the project on the cluster:

      start_project.sh
    Windows Open a command window:
    1. Start the example cluster:

      start_server_cluster.bat

    2. Add project to the cluster, and start it on the cluster:

      start_project.bat
  2. Start esp_subscriber to subscribe to the project that is running on the cluster.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./esp-subscribe.sh
    Windows Open a command window and enter:

    esp-subscribe.bat
  3. Starts the AsapSource and FileSink components.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./asapToFile.sh
    Windows Open a command window and enter:

    asapToFile.bat
  4. Upload data from the esp_insert.txt file to the Server.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./esp_upload.sh
    Windows Open a command window and enter:

    esp_upload.bat
    AsapSource reads this published data from the Server and passes it to FileSink, which writes it to the out.txt file.
Parent topic: Examples
Related reference
AsapSource Properties