Hello everyone,
I am reading the change stream from Spanner using the Spanner client. I attempted to use StreamedResultSet, but I'm having trouble resolving it. Could someone please help me with mapping the metadata and values from the results when I run execute_streaming_sql? Thank you!
request = spanner_v1.ExecuteSqlRequest( session=session.name, sql=f"SELECT * FROM READ_spanner_all_change_stream( start_timestamp => '{current_time}', end_timestamp => NULL, partition_token => NULL, heartbeat_milliseconds => 10000)", ) result_set = spanner_client.execute_streaming_sql(request=request)