Method put_item

feapder/buffer/item_buffer.py:119–124

(self, item)

        self._started.clear()

    def put_item(self, item):
        if isinstance(item, Item):
            # 入库前的回调
            item.pre_to_db()

        self._items_queue.put(item)

    def flush(self):
        try: