123456789101112131415161718192021222324252627282930313233343536373839404142 |
- # coding=utf-8
- import pandas
- from base import init_env
- init_env(True)
- from apps.web.user.models import InsuranceOrder
- def get_data():
- dataList = list()
- for _order in InsuranceOrder.objects.all():
- _data = _order.to_dict()
- _data["date"] = _data["dateTimeAdded"][:10]
- dataList.append(_data)
- return dataList
- def parse(dataList):
- dataF = pandas.DataFrame(dataList)
- print "每天的人数----------------\n", dataF.groupby("date")["openId"].count()[:100]
- print "单人次购买平均数: ", dataF.groupby("openId")["date"].count()
- print "购买次数大于2的人数: ", len(dataF.groupby("openId").filter(lambda x: len(x) >= 3))
- def main():
- dataList = get_data()
- parse(dataList)
- if __name__ == '__main__':
- main()
|