|
@@ 75-86 (lines=12) @@
|
| 72 |
|
logger.info("cost %.2fs, %.2f/s %.2fms", |
| 73 |
|
cost_time, n * 1.0 / cost_time, cost_time / n * 1000) |
| 74 |
|
|
| 75 |
|
def test_update(n, start=0): |
| 76 |
|
logger.info("taskdb update %d" % n) |
| 77 |
|
start_time = time.time() |
| 78 |
|
for i in range(n): |
| 79 |
|
task['url'] = 'http://bench.pyspider.org/?l=%d' % (i + start) |
| 80 |
|
task['taskid'] = md5string(task['url']) |
| 81 |
|
task['track'] = track |
| 82 |
|
taskdb.update(task['project'], task['taskid'], task) |
| 83 |
|
end_time = time.time() |
| 84 |
|
cost_time = end_time - start_time |
| 85 |
|
logger.info("cost %.2fs, %.2f/s %.2fms", |
| 86 |
|
cost_time, n * 1.0 / cost_time, cost_time / n * 1000) |
| 87 |
|
|
| 88 |
|
request_task_fields = [ |
| 89 |
|
'taskid', |
|
@@ 62-73 (lines=12) @@
|
| 59 |
|
} |
| 60 |
|
} |
| 61 |
|
|
| 62 |
|
def test_insert(n, start=0): |
| 63 |
|
logger.info("taskdb insert %d", n) |
| 64 |
|
start_time = time.time() |
| 65 |
|
for i in range(n): |
| 66 |
|
task['url'] = 'http://bench.pyspider.org/?l=%d' % (i + start) |
| 67 |
|
task['taskid'] = md5string(task['url']) |
| 68 |
|
task['track'] = {} |
| 69 |
|
taskdb.insert(task['project'], task['taskid'], task) |
| 70 |
|
end_time = time.time() |
| 71 |
|
cost_time = end_time - start_time |
| 72 |
|
logger.info("cost %.2fs, %.2f/s %.2fms", |
| 73 |
|
cost_time, n * 1.0 / cost_time, cost_time / n * 1000) |
| 74 |
|
|
| 75 |
|
def test_update(n, start=0): |
| 76 |
|
logger.info("taskdb update %d" % n) |
binux /
pyspider
