(self)
| 105 | return self._mysql_pipeline |
| 106 | |
| 107 | def run(self): |
| 108 | self._thread_stop = False |
| 109 | while not self._thread_stop: |
| 110 | self.flush() |
| 111 | tools.delay_time(setting.ITEM_UPLOAD_INTERVAL) |
| 112 | |
| 113 | self.close() |
| 114 | |
| 115 | def stop(self): |
| 116 | self._thread_stop = True |