zeppelin_sample.py

%pyspark
import sys
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.transforms import *

# Create a Glue context
glueContext = GlueContext(SparkContext.getOrCreate())

# Create a DynamicFrame using 
# the 'performance_reports' table
performance_DyF = glueContext.create_dynamic_frame\
	.from_catalog(
	  database="reports",
	  table_name="performance_reports")

# Print out information about this data
print("Records Count:  ", performance_DyF.toDF().count())
performance_DyF.printSchema()