def _process_chat (message, record):


    # chat_title = CharField(null = True, max_length = 250)
    # chat_id = IntegerField()
    # chat_username= CharField(null = True, max_length = 250)
    # chat_first_name = CharField(null = True, max_length = 250)
    # chat_last_name = CharField(null = True, max_length = 250)

    # u'chat':{
    #   u'username':u'dude',
    #   u'first_name':u'first',
    #   u'last_name':u'last',
    #   u'id':12345
    # }

    # u'chat':{
    #   u'id':-12345,
    #   u'title':u'A Group Chat'
    # }

    if 'title' in message['chat']:
        record.chat_title = message['chat']['title']

    if 'id' in message['chat']:
        record.chat_id = message['chat']['id']

    if 'username' in message['chat']:
        record.chat_username = message['chat']['username']

    if 'first_name' in message['chat']:
        record.chat_first_name = message['chat']['first_name']

    if 'last_name' in message['chat']:
        record.chat_last_name = message['chat']['last_name']

    return record
Go back using the cached bytes.
dataset/ETHPy150Open leonjza/hogar/hogar/Plugins/Logger/main.py/_process_chat--crossover with--dataset/ETHPy150Open mtth/hdfs/hdfs/ext/avro/__init__.py/_SeekableReader.seek