Skip to main content

​
Description

The query() function is executed on a view that resides in one of the projects.

​
Syntax

Here is the syntax: 
project_name.query('SELECT * FROM my_project.my_view LIMIT 100')
You can query for newly added data using the functionality introduced by the LAST keyword as follows: 
query = server.databases.my_data_source.views.view_name.filter(column_name='value').track('timestamp_column')

# first call returns no records
df = query.fetch()

# second call returns rows with timestamp_column greater than the timestamp of a previous fetch
df = query.fetch()