Book Image

Building Python Real time Applications with Storm

Book Image

Building Python Real time Applications with Storm

Overview of this book

Big data is a trending concept that everyone wants to learn about. With its ability to process all kinds of data in real time, Storm is an important addition to your big data “bag of tricks.” At the same time, Python is one of the fastest-growing programming languages today. It has become a top choice for both data science and everyday application development. Together, Storm and Python enable you to build and deploy real-time big data applications quickly and easily. You will begin with some basic command tutorials to set up storm and learn about its configurations in detail. You will then go through the requirement scenarios to create a Storm cluster. Next, you’ll be provided with an overview of Petrel, followed by an example of Twitter topology and persistence using Redis and MongoDB. Finally, you will build a production-quality Storm topology using development best practices.
Table of Contents (14 chapters)

Running the topology


We have a few more small items to address before we run the topology:

  1. Copy the logconfig.ini file from the second example in Chapter 3, Introducing Petrel, to this topology's directory.

  2. Create a file called setup.sh. Petrel will package this script with the topology and run it at startup. This script installs the third-party Python libraries used by the topology. The file looks like this:

    pip install -U pip
    pip install nltk==3.0.1 oauthlib==0.7.2 tweepy==3.2.0
  3. Create a file called manifest.txt with these two lines:

    logconfig.ini
    setup.sh
  4. Before running the topology, let's review the list of files that we've created. Make sure you have created these files correctly:

    • topology.yaml

    • twitterstream.py

    • splitsentence.py

    • rollingcount.py

    • intermediaterankings.py

    • totalrankings.py

    • manifest.txt

    • setup.sh

  5. Run the topology with this command:

    petrel submit --config topology.yaml --logdir `pwd`

Once the topology starts running, open another terminal in the topology directory. Enter the following...