in retail/recommendation-system/bqml-scann/embeddings_exporter/pipeline.py [0:0]
def to_csv(entry):
item_Id = entry['item_Id']
embedding = entry['embedding']
csv_string = f'{item_Id},'
csv_string += ','.join([str(value) for value in embedding])
return csv_string