def _message_pb_from_mapping(message):
 return PubsubMessage(data=_to_bytes(message['data']), attributes=message['attributes'])

def _message_pb_from_mapping ( message ) : return PubsubMessage ( data = _to_bytes ( message [ 'data' ] ) , attributes = message [ 'attributes' ] )
helper for :meth:_publisherapi .