@staticmethod
def process(element, publish_time=beam.DoFn.TimestampParam):
    'Processes each incoming windowed element by extracting the Pub/Sub\n        message and its publish timestamp into a dictionary. `publish_time`\n        defaults to the publish timestamp returned by the Pub/Sub server. It\n        is bound to each element by Beam at runtime.\n        '
    (yield {'message_body': element.decode('utf-8'), 'publish_time': datetime.datetime.utcfromtimestamp(float(publish_time)).strftime('%Y-%m-%d %H:%M:%S.%f')})
Processes each incoming windowed element by extracting the Pub/Sub
message and its publish timestamp into a dictionary. `publish_time`
defaults to the publish timestamp returned by the Pub/Sub server. It
is bound to each element by Beam at runtime.
@staticmethod
def process(element, publish_time=beam.DoFn.TimestampParam):
    'Processes each incoming windowed element by extracting the Pub/Sub\n        message and its publish timestamp into a dictionary. `publish_time`\n        defaults to the publish timestamp returned by the Pub/Sub server. It\n        is bound to each element by Beam at runtime.\n        '
    (yield {'message_body': element.decode('utf-8'), 'publish_time': datetime.datetime.utcfromtimestamp(float(publish_time)).strftime('%Y-%m-%d %H:%M:%S.%f')})