in lambda/demo_handler.py [0:0]
def do_upsert(body):
stmt = session.prepare("INSERT INTO cassandra_demo.country_cities (country, city_name, population) VALUES (?, ?, ?)")
execution_profile = session.execution_profile_clone_update(session.get_execution_profile(EXEC_PROFILE_DEFAULT))
execution_profile.consistency_level = ConsistencyLevel.LOCAL_QUORUM
session.execute(stmt, body.values(), execution_profile=execution_profile)