How to Run a PySpark Notebook with Docker

By Prabeesh Keezhathra

- 4 minutes read - 829 words

Apache Spark is a powerful big data processing engine that is well-suited for use in a distributed environment. One way to interact with Spark is through the use of an IPython Notebook, which allows you to run and debug your Spark code in an interactive manner. This tutorial will guide you through the process of setting up and running a PySpark Notebook using Docker.

Installing Docker

Docker is a containerization platform that allows you to package and deploy your applications in a predictable and isolated environment.

To install Docker, use the following command. This command was run on an Ubuntu-14-04 instance, but you can find more options on the Docker official site.

# This command installs Docker on your machine
wget -qO- https://get.docker.com/ | sh

Running the PySpark Notebook

To run the PySpark Notebook, use the following command on any machine with Docker installed.

# This command runs the pyspark-notebook Docker container and exposes port 8888 for access to the notebook
docker run -d -t -p 8888:8888 prabeeshk/pyspark-notebook

After the pyspark-notebook Docker container is up and running, you can access the PySpark Notebook by directing your web browser to http://127.0.0.1:8888 or http://localhost:8888.

For more information on the Docker image, check out the Dockerhub repository.

The source code can be found in the GitHub repository. Below, you will find the the custom PySpark startup script and the Dockerfile.

## PySpark Startup Script

# Import required modules
import os
import sys

# Get the value of the SPARK_HOME environment variable
spark_home = os.environ.get('SPARK_HOME', None)

# If SPARK_HOME is not set, raise an error
if not spark_home:
raise ValueError('SPARK_HOME environment variable is not set')

# Add the paths to the Python libraries for Spark and py4j to the system path
sys.path.insert(0, os.path.join(spark_home, 'python'))
sys.path.insert(0, os.path.join(spark_home, 'python/lib/py4j-0.8.2.1-src.zip'))

# Execute the pyspark shell script to launch PySpark
execfile(os.path.join(spark_home, 'python/pyspark/shell.py'))

This script is used to start PySpark in an IPython Notebook. It does this by importing the necessary os and sys modules and getting the value of the SPARK_HOME environment variable. If SPARK_HOME is not set, the script raises a ValueError. The script then adds the paths to the Python libraries for Spark and py4j to the system path and executes the pyspark shell script to launch PySpark in the IPython Notebook. The purpose of this script is to ensure that the required Python libraries for working with PySpark are present and that PySpark is properly initialized when the IPython Notebook is launched.

## Dockerfile
FROM ubuntu:trusty

MAINTAINER Prabeesh Keezhathra.

# Update the package list and install Java
RUN \
    apt-get -y update &&\
    echo "deb http://ppa.launchpad.net/webupd8team/java/ubuntu precise main" > /etc/apt/sources.list.d/webupd8team-java.list &&\
    echo "deb-src http://ppa.launchpad.net/webupd8team/java/ubuntu precise main" >> /etc/apt/sources.list.d/webupd8team-java.list &&\
    apt-key adv --keyserver keyserver.ubuntu.com --recv-keys EEA14886 &&\
    apt-get -y update &&\
    echo oracle-java7-installer shared/accepted-oracle-license-v1-1 select true | /usr/bin/debconf-set-selections &&\
    apt-get install -y oracle-java7-installer &&\
    apt-get install -y curl

# Set the version of Spark to install and the installation directory
ENV SPARK_VERSION 1.4.0
ENV SPARK_HOME /usr/local/src/spark-$SPARK_VERSION

# Download and extract Spark to the installation directory and build Spark
RUN \
    mkdir -p $SPARK_HOME &&\
    curl -s http://d3kbcqa49mib13.cloudfront.net/spark-$SPARK_VERSION.tgz | tar -xz -C $SPARK_HOME --strip-components=1 &&\
    cd $SPARK_HOME &&\
    build/mvn -DskipTests clean package

# Set the Python path to include the Spark installation
ENV PYTHONPATH $SPARK_HOME/python/:$PYTHONPATH

# Install build essentials, Python, and the Python package manager pip
RUN apt-get install -y build-essential \
    python \
    python-dev \
    python-pip \
    python-zmq

# Install Python libraries for interacting with Spark
RUN pip install py4j \
    ipython[notebook]==3.2 \
    jsonschema \
    jinja2 \
    terminado \
    tornado

# Create an IPython profile for PySpark
RUN ipython profile create pyspark

# Copy the custom PySpark startup script to the IPython profile directory
COPY pyspark-notebook.py /root/.ipython/profile_pyspark/startup/pyspark-notebook.py

# Create a volume for the notebook directory
VOLUME /notebook

# Set the working directory to the notebook directory
WORKDIR /notebook

# Expose port 8888 for the IPython Notebook server
EXPOSE 8888

# Run IPython with the PySpark profile and bind to all interfaces
CMD ipython notebook --no-browser --profile=pyspark --ip=*

This Dockerfile creates a Docker image for running a PySpark Notebook. It does this by using the ubuntu:trusty base image and installing Java and several required packages, such as build essentials and Python. It then downloads and installs Apache Spark, sets the Python path to include the Spark installation, and installs Python libraries for interacting with Spark. The Dockerfile also creates an IPython profile for PySpark and copies a custom PySpark startup script to the profile directory. Finally, it creates a volume for the notebook directory, sets the working directory to the notebook directory, exposes port 8888 for the IPython Notebook server, and runs IPython with the PySpark profile, binding to all interfaces.

This tutorial has shown you how to run a PySpark Notebook using Docker. The steps outlined in this tutorial guided you through installing Docker and running a PySpark Notebook, allowing you to take advantage of the interactive and debugging capabilities of the IPython Notebook while working with Spark, making it easier to analyze your data.

    Related Posts

    comments powered by Disqus