analyser.py

import time
import numpy as np
import sqlite3
from bilibili_api import comment, sync , video, settings,Credential
import asyncio



async def main():
    conn = sqlite3.connect('data.db')
    cursor = conn.execute("select bvid from bilibili_rank_video limit 4500,3000 ")

    count = 0
    for it in cursor:
        bid = ''.join(it)
        try:
            # 获取视频信息
            v = video.Video(bvid=bid)
            info = await v.get_info()

            display = [bid, info['tname'], info['title'], info['duration'], info['owner']['mid'], \
                       info['owner']['name'], info['stat']['view'], info['stat']['like'], info['stat']['coin'],
                       info['stat']['favorite']]
        except Exception as e:
            print(e)
        # 打印视频信息
        print(display)
        result = np.array(display)
        command = "insert into video_info \
                         values(?,?,?,?,?,?,?,?,?,?);"
        try:
            conn.execute(command, result)
        except Exception as e:
            print(e)

        count += 1
        #防止中途被封丢失数据，每200写一次
        if count % 200 ==0:
            conn.commit()
            print('当前写入数目：'+str(count))
        time.sleep(0.1)
    conn.commit()
    conn.close()
if __name__ == '__main__':
    # 主入口
    asyncio.get_event_loop().run_until_complete(main())