in flex-templates/python/regional_dlp_de_identification/pubsub_dlp_bigquery.py [0:0]
def process(self, element, **kwargs):
request = {
'parent': self.params['parent'],
'item': element
}
if self.config['deidentify_template_name'] is not None:
request['deidentify_template_name'] = \
self.config['deidentify_template_name']
else:
request['deidentify_config'] = self.config['deidentify_config']
operation = self.client.deidentify_content(
timeout=self.timeout,
request=request
)
yield operation.item