def do_upsert()

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)