pipe.py 文件源码

python
阅读 30 收藏 0 点赞 0 评论 0

项目:gae-dataflow 作者: amygdala 项目源码 文件源码
def process(self, element):

    created_at = element.properties.get('created_at', None)
    cav = None
    if created_at:
      cav = created_at.timestamp_value
      cseconds = cav.seconds
    else:
      return
    crdt = datetime.datetime.fromtimestamp(cseconds)
    logging.warn("crdt: %s", crdt)
    logging.warn("earlier: %s", self.earlier)
    if crdt > self.earlier:
      # return only the elements (datastore entities) with a 'created_at' date
      # within the last self.days days.
      yield element
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号