Install GeoAnalytics Engine on Google Cloud Dataproc

Google Cloud Dataproc is a fully managed and highly scalable service for running Apache Spark and other open-source tools and frameworks. Using the steps outlined below, GeoAnalytics Engine can be leveraged within a PySpark notebook hosted in Google Dataproc.

To complete this install you will need:

• An active subscription to Google Cloud Platform

• GeoAnalytics Engine install files

• A GeoAnalytics Engine subscription, or a license file.

Prepare the workspace

1. Log in to the Google Cloud Console.

2. Select an existing project or set-up a new one.

3. Create a Google Cloud Storage bucket in the same region you plan to deploy a cluster in.

4. Upload the geoanalytics.jar file and the geoanlytics.whl file to your bucket.

5. Copy and paste the text below into a text editor and save it as a .sh script. Replace <bucket-name>, <jar-file-name>, and <wheel-file-name> with the paths to the bucket name, the jar file name, and the wheel name from step 4. Save the script and upload it to your bucket.

   Use dark colors for code blocksCopy

                                                              

   1
   2
   3
   4
   5
   6
   7
   8
   9
   10
   11
   12
   13
   14
   15
   16
   17
   18
   19
   20
   21
   22
   23
   24
   25
   26
   27
   28
   29
   30
   31
   32
   33
   34
   35
   36
   37
   38
   39
   40
   41
   42
   43
   44
   45
   46
   47
   48
   49
   50
   51
   52
   53
   54
   55
   56
   57
   58
   59
   #!/bin/bash
   
   BUCKET_NAME=<bucket-name>
   JAR_FILE=<jar-file-name>
   WHL_FILE=<wheel-file-name>
   
   WHL_PATH="gs://${BUCKET_NAME}/${WHL_FILE}"
   JAR_PATH="gs://${BUCKET_NAME}/${JAR_FILE}"
   tmpdir=$(dirname $(mktemp -u))
   
   gsutil cp "${JAR_PATH}" "/usr/lib/spark/jars"
   gsutil cp "${WHL_PATH}" "${tmpdir}"
   
   #https://github.com/GoogleCloudDataproc/initialization-actions/blob/master/python/pip-install.sh
   
   set -exo pipefail
   readonly PACKAGES="${tmpdir}/${WHL_FILE}"
   function err() {
   echo "\[$(date +'%Y-%m-%dT%H:%M:%S%z')\]: $\*"
   exit 1
   }
   
   function run_with_retry() {
   local -r cmd=("$@")
   for ((i = 0; i \< 10; i++)); do
   if "${cmd[@]}"; then
   return 0
   fi
   sleep 5
   done
   err "Failed to run command: ${cmd\[*]}"
   }
   
   function install_pip() {
   if command -v pip \>/dev/null; then
   echo "pip is already installed."
   return 0
   fi
   if command -v easy_install \>/dev/null; then
   echo "Installing pip with easy_install..."
   run_with_retry easy_install pip
   return 0
   fi
   echo "Installing python-pip..."
   run_with_retry apt update
   run_with_retry apt install python-pip -y
   }
   
   function main() {
   if \[\[ -z "${PACKAGES}" \]\]; then
   echo "ERROR: Must specify PIP PACKAGES. A space separated list of
   packages to install. Packages can contain version selector"
   exit 1
   fi
   install_pip
   run_with_retry pip install --upgrade ${PACKAGES}
   }
   
   main
   

Create a cluster

1. Navigate to Google Dataproc and open the Dataproc Create a cluster page.

2. Choose a Name, Location, Cluster Type, and Autoscaling policy that meet your requirements.

3. Under Versioning, choose a supported Google Dataproc image.

4. Under Component Gateway select "Enable component gateway".

5. Select any Optional components you may require. You must select at least either "Jupyter Notebook" or "Zeppelin Notebook".

6. Click Configure nodes and update the Master node and Worker node configurations to meet your requirements. Change other settings as needed.

7. Click Customize cluster and adjust the settings for Network configuration, Internal IP only, Dataproc Metastore, and Labels or keep the defaults.

8. Add the three properties in the table below to Cluster properties:

   Prefix	Key	Value
   spark	spark.plugins	com.esri.geoanalytics.Plugin
   spark	spark.serializer	org.apache.spark.serializer.KryoSerializer
   spark	spark.kryo.registrator	com.esri.geoanalytics.KryoRegistrator

9. Under Initialization actions, browse to the .sh script you uploaded previously and select it as the Executable file.

10. Adjust any remaining settings in Customize cluster as needed or keep the defaults.

11. Adjust any settings within the Manage security page or keep the defaults.

12. Click Create to create the cluster.

Authorize GeoAnalytics Engine

1. Find the Web Interfaces page on the cluster you created previously. Open a Jupyter, JupyterLab or Zeppelin notebook by clicking on the corresponding Component gateway.

2. Import the geoanalytics library and authorize it using your username and password or another supported authorization method. See Licensing and Authorization for more information. For example:

   Use dark colors for code blocksCopy

     

   1
   2
   import geoanalytics
   geoanalytics.auth(username="User1", password="p@ssw0rd")

3. Try out the API by importing the SQL functions as an easy-to-use alias like ST and listing the first 20 functions in a notebook cell:

   Use dark colors for code blocksCopy

     

   1
   2
   from geoanalytics.sql import functions as ST
   spark.sql("show user functions like 'ST_*'").show()

What’s next?

You can now use any SQL function or analysis tool in the geoanalytics module.

See Data sources and Using DataFrames to learn more about how to access your data from your notebook. Also see Visualize results to get started with viewing your data on a map. For examples of what else is possible with GeoAnalytics Engine, check out the sample notebooks, tutorials, and blog posts.