python
import psycopg2
conn = psycopg2.connect("dbname=pipelinedb user=postgres")
query = "CREATE CONTINUOUS VIEW page_views AS SELECT * FROM events WHERE event_type = 'page_view';"
with conn.cursor() as cursor:
cursor.execute(query)
with conn.cursor() as cursor:
cursor.execute("SELECT * FROM page_views;")
for row in cursor:
print(row)
conn.close()
