create_query_lambda.py

def create_query_lambda(rs):
    # Create a query builder obj and run your SQL query
    u = rs.sql(Q('s3sparkPythonMoviesColTrue').where(F["video"] == "True").limit(1))
    print(u)

    # create a query builder object
    q = Q('s3sparkPythonMoviesColTrue').where(F["video"] == "True").limit(1)

    # create a new Query Lambda
    qlambda = rs.QueryLambda.create('sparkRocksetQLVideo', workspace='commons',query=q,)

    # execute a Query Lambda
    results = qlambda.execute()

    print(results)