littlecodersh / danmu Goto Github PK

View Code? Open in Web Editor NEW

717.0 37.0 149.0 34 KB

Python 弹幕包 A live danmu package for python

License: Other

Python 100.00%

danmu douyu panda bilibili

danmu's Introduction

danmu

English Version

danmu 是一个开源的直播平台弹幕接口，使用他没什么基础的你也可以轻松的操作各平台弹幕。

使用不到三十行代码，你就可以使用Python基于弹幕进一步开发。

支持斗鱼、熊猫、战旗、全民、Bilibili多平台弹幕。

支持各版本Python，无平台依赖，方便各类开发者、爱好者使用。

一次开启，主播上线自动连接，下线后上线自动重连。

经过深度优化，几乎不漏过任何一条弹幕；使用抽象构架，方便修改与开发。

Documents

你可以在这里获取使用帮助。

Installation

可以通过本命令安装 danmu：

pip install danmu

Simple uses

通过如下代码，可以初步通过Python对弹幕进行处理。

import time, sys

from danmu import DanMuClient

def pp(msg):
    print(msg.encode(sys.stdin.encoding, 'ignore').
        decode(sys.stdin.encoding))

dmc = DanMuClient('http://www.douyu.com/lslalala')
if not dmc.isValid(): print('Url not valid')

@dmc.danmu
def danmu_fn(msg):
    pp('[%s] %s' % (msg['NickName'], msg['Content']))

@dmc.gift
def gift_fn(msg):
    pp('[%s] sent a gift!' % msg['NickName'])

@dmc.other
def other_fn(msg):
    pp('Other message received')

dmc.start(blockThread = True)

Screenshot

Advanced uses

设置默认的消息处理方式

消息被分为三种类型注册：danmu, gift, other

分别对应：普通弹幕，礼物消息，其他消息

如果某种类型没有注册过，将会使用默认方法，默认方法的注册方式如下：

from danmu import DanMuClient

dmc = DanMuClient('http://www.douyu.com/lslalala')

@dmc.default
def default_fn(msg):
    pp('[%s] %s' % (msg['NickName'], msg['Content']))

取消已经注册过的方法

通过以下方式可以取消某一种类型的注册。

from danmu import DanMuClient

dmc = DanMuClient('http://www.douyu.com/lslalala')
dmc.default(None)
dmc.gift(None)

FAQ

Q: 获取的消息格式都是什么？

A: 消息为一个字典，必有三个键：NickName、Content、MsgType，对应用户名、消息内容、消息类型。

Comments

如果有什么问题或者建议都可以在这个Issue和我讨论

或者也可以在gitter上交流：

danmu's People

Contributors

Stargazers

Watchers

Forkers

chongdianbao jansusea caobaibing eroszy feixuqy awesome-archive erichuang1994 pierre94 locusxt eaglewei kdashl cool-robot tempdban dfsit beerpoet ldream lqruui rickyshijs olachan socialloser1 liambao hifuck devenlu zhy77 mwqdream wangroot maweis1981 ted-ch ztyoung86 invs007 yingxuanxuan weisingxcw lcod dofine osgh benliinz replive flyrainkey wongqueng superway117 oyl zhangzhaolei zhanglei huangkbaaron glh88 oiccc rubyfrea zhao9jack prentice8698 lchloride haigendong gopricy yefengo mayfool find0day frankiegu rgwt123 littlewrite qingyuj yemaobumei easy10010 ronkillerman xfy447 longbai csujin athx dorain sjc74364 xh286286 oodavy41 stanyaha eleflea caohai01 firebrother chanchancl yanetut guswrolland czastack ytong82 ghp268 jianxunrao towingtop yugimaster herunkang2018 xuwei95 jemygraw riverlight lincry jawayh smilemilk1992 lki pythonaihaitao crackercat fatty-ricky givemeablock songzcn aspd199 zhangsheng377 glgameshrin mssc008

danmu's Issues

有时候能爬到弹幕有时候什么反应都没有

python test.py
success
但是爬不到东西

昨天晚上还能爬到东西的,同样的设置早上就爬不到了 ,换了好几个正在直播的页面都爬不到

import time
import sys
reload(sys)
sys.setdefaultencoding('utf-8')
from danmu import DanMuClient

def pp(msg):
    print(msg.encode(sys.stdin.encoding, 'ignore').
        decode(sys.stdin.encoding))

dmc = DanMuClient('https://www.douyu.com/778895')
if not dmc.isValid(): print('Url not valid')
else: print ('success')

@dmc.danmu
def danmu_fn(msg):
    pp('[%s] %s' % (msg['NickName'], msg['Content']))
    with open ('danmu.txt','a') as f:
      #  f.write('%s [%s] %s \n' % (time.strftime("%a %b %d %H:%M:%S %Y", time.localtime()) ,msg['NickName'], msg['Content'])
		f.write('%s \n' %(msg['Content']))
		
@dmc.gift
def gift_fn(msg):
    pp('[%s] sent a gift!' % content['NickName'])

@dmc.other
def other_fn(msg):
    pp('Other message received')

dmc.start(blockThread = True)

[误报]无法获取礼物消息

问题描述：

斗鱼，全民，熊猫，战旗这4个平台测试了有50个主播，都只能截获到普通danmu消息，礼物的截获不到，求大神指教

系统：

centos6.5

代码：

@dmc.danmu
def danmu_fn(msg):
    payload = {
        "star_id": star_id,
        "text": msg['Content'],
        "type": "danmu",
        "plat": plat
    }
    r = requests.get("http://localhost:9203/save", params=payload)
@dmc.gift
def gift_fn(msg):
    pp('[%s] sent a gift!' % content['NickName'])
    payload = {
        "star_id": star_id,
        "text": "gift",
        "type": "gift",
        "plat": plat
    }
    r = requests.get("http://localhost:9203/save", params=payload)
@dmc.other
def other_fn(msg):
    pp('Other message received')

dmc.start(blockThread = True)

pandatv 运行无反应

import time, sys

from danmu import DanMuClient

def pp(msg):
    print(msg.encode(sys.stdin.encoding, 'ignore').
        decode(sys.stdin.encoding))

#dmc = DanMuClient('https://www.douyu.com/32892')
#dmc = DanMuClient('https://live.bilibili.com/324')
dmc = DanMuClient('https://www.panda.tv/66666')

if not dmc.isValid(): print('Url not valid')

@dmc.danmu
def danmu_fn(msg):
    pp('[%s] %s' % (msg['NickName'], msg['Content']))

@dmc.gift
def gift_fn(msg):
    pp('[%s] sent a gift!' % msg['NickName'])

@dmc.other
def other_fn(msg):
    pp('Other message received')

dmc.start(blockThread=True)

init.py里面set_logging并未使用且会造成重复输出

如果项目里面也使用了logging模块的话，输出信息会变为2条
注释from .log import set_logging恢复正常

前几天是好的，这几天出现这种情况
λ python pilirun.py
Traceback (most recent call last):
File "pilirun.py", line 3, in
from danmu import DanMuClient
ModuleNotFoundError: No module named 'danmu'
用的anaconda带的python，装的时候是3.5版本，这两天看了好像自动升级到3.6版本了，是不是因为3.6不兼容的原因？

记录器失效

如题，不显示弹幕了。。。

交互模式确定

@tempdban
兄弟，我在想这个包应该做成什么样子给用户使用。
没找到什么好的想法，有什么建议吗？

可以发弹幕么？

能不能把用户的基础熟悉全部获取到

斗鱼可以更改用户名,但是获取弹幕的时候没有获取uid

怎么停止正在爬取的弹幕操作

如果我正在爬取斗鱼的弹幕信息，我现在要立刻停止怎么操作啊？

其他平台实现问题

想问一下大佬们，douyu这些是平台给了接口才能访问到的吗，如果平台没有给接口该如何拿到数据？

zhanqi.tv也失效了

试了好几个好像只剩douyu能用了。。。

Panda失效

http://m.panda.tv/66666
这个API似乎不再可用了
http://www.panda.tv/ajax_chatroom?roomid=%s&_=%s'%(roomId, str(int(time.time())))

HuomaoTV 失效求助

如题.

斗鱼新的url地址获取不到roomid

例如这种房间地址：https://www.douyu.com/topic/nzds?rid=5395900
需要增加正则匹配 room_id = re.findall(r'rid=(\d{1,7})', url)[0]

不支持网易cc

清楼主试试网易cc

cannot import name 'DanMuClient'

Traceback (most recent call last):
File "D:/Users/yidian/PycharmProjects/trans/danmu.py", line 3, in
from danmu import DanMuClient;
File "D:\Users\yidian\PycharmProjects\trans\danmu.py", line 3, in
from danmu import DanMuClient;
ImportError: cannot import name 'DanMuClient'

斗鱼‘’55开’ 等大主播容易卡住弹幕不动但会自动重连（丢失部分弹幕！）太快太多？压测？

如题

老铁求个2.7版本py脚本的写法

如题。

DOUYU 弹幕不行了

dmc.start(blockThread=False)没有输出

我设置为false时debug _start()方法的断点没走，程序没有输出是什么情况

功能与意见反馈，报bug可以另开issue

这里不回答python的基础问题，只做意见收集用途。
所有意见我都会及时回复的~
报bug记得另开issue。

斗鱼弹幕部分失效

socket收到的只有type@=dgb的，即只能收到礼物和其他

是服务器分开了吗

[bug]斗鱼礼物消息重复

这个是官方行为还是bug呢？

DouYu Danmu issue

i find a problem that when using DanmuClient, some new douyu room url seems not wroking for the same version client, ex: 'https://www.douyu.com/65000'
but some other douyu_url i crawled before is also useful, did someone has the same problem here ?

斗鱼bug

获取弹幕的时候,如果有用户发送礼物会报错

运行后无反应，一段时间后报错

fangs-mac:danmu fang$ python3 a.py
^CTraceback (most recent call last):
File "a.py", line 24, in
dmc.start(blockThread = True)
File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/site-packages/danmu/init.py", line 55, in start
self.__client.start()
File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/site-packages/danmu/Abstract.py", line 29, in start
time.sleep(self.anchorStatusRescanTime)
KeyboardInterrupt

可否添加启动弹幕的同时打开播放器

比如我安装了mpv,youtube-dl

运行 python run.py 后,同时运行 mpv https://www.douyu.com/32892 来打开播放器观看在线视频

谢谢楼主提供的好软件