разница MongoDB к предыдущей записи

Question

У меня есть коллекция MongoDB, которые содержат следующее:

[{'price': 0.74881,, 
    'date': '20160601 00:00:00.134', 
    'instrument': 'EUR/GBP'}, 
{'price': 0.76881, 
    'date': '20160601 00:00:00.135', 
    'instrument': 'EUR/GBP'}, 
{'price': 0.78881, 
    'date': '20160601 00:00:00.300', 
    'instrument': 'EUR/GBP'}, 
{'price': 1.76881, 
    'date': '20160601 00:00:00.302', 
    'instrument': 'EUR/GBP'}, 

Как я могу обновить каждую запись, так что содержит процентное увеличение/уменьшение спроса и предложения к предыдущей записи? Реальная запись содержит миллионы записей, поэтому панды не подходят.

В выводе каждая запись должна содержать содержать дополнительное поле в каждой записи называется price_change_to_pervious_item

Answer 1

Похоже, что вы хотите обрабатывать ваши записи в парной моде. Эта функция от самого itertools documentation.

from itertools import tee, izip 

def pairwise(iterable): 
    "s -> (s0,s1), (s1,s2), (s2, s3), ..." 
    a, b = tee(iterable) 
    next(b, None) 

    return izip(a, b) 

После того как вы это, и если предположить, что ваши данные сортируются

results = [] 
for d1, d2 in pairwise(data): 
    if not result: 
    d1['price_change_to_pervious_item'] = 0.0 
    results.append(d1) 
    delta = d2['price'] - d1['price'] 
    d2['price_change_to_pervious_item'] = delta 
    results.append(d2) 

Это не тестировалось, но вы получите общее представление. Pairwise позволяет обрабатывать строки в режиме (d1, d2), (d2, d3).