#Python

kafka-python的gevent模式和kafka的兼容性

使用gevent会杀死kafka的consumer线程;据查:kafka-python对gevent的支持不是太好,可以使用pykafka;但是可以kafka-python可以结合eventlet使用https://www.zhihu.com/question/31809734...

kafak-python使用补充

 kafka-python的心跳报文使用的是一个独立的线程,以固定的时间(heartbeat_interval_ms,默认是3000ms)间隔发生心跳信息member_id唯一标识一个客户端的consumer使用group模式下,在一个consumer连接的过程中,如果遇到有其他consumer加入或者退出同...
代码星球 ·2020-04-06

CodeReview工具Gerrit的python库pygerrit2

 源代码:https://github.com/dpursehouse/pygerrit2...

python文档生成工具:pydoc、sphinx;django如何使用sphinx?

文档生成工具:自带的pydoc,比较差建议使用sphinx安装:pipinstallsphinx安装主题:由各种主题,我选择常用的sphinx_rtd_themepipinstallsphinx_rtd_theme使用方法:1、创建文件夹doc:mkdirdoc;cddoc;执行sphinx-quickstart,进入...

python抽象类的实现方式:abc模块

abc:abstractbaseclass文档:https://docs.python.org/zh-cn/3.7/library/abc.html参考:https://www.cnblogs.com/wancy86/p/6269553.html?utm_source=itdadao&utm_medium=re...

python的重试库tenacity用法以及类似库retry、requests实现

介绍tenacityisanApache2.0licensedgeneral-purposeretryinglibrary,writteninPython,tosimplifythetaskofaddingretrybehaviortojustaboutanything.Itoriginatesfromaforkofr...

python读取yaml配置文件

支持多种语言:python、js、golang、java、c、c++YAML语言(发音/ˈjæməl/)的设计目标,就是方便人类读写。它实质上是一种通用的数据串行化格式。它的基本语法规则如下。大小写敏感使用缩进表示层级关系缩进时不允许使用Tab键,只允许使用空格。缩进的空格数目不重要,只要相同层级的元素左侧...

python3.7新增关键字:async、await;带来和kafka-python==1.4.2的兼容性问题

python3.7新增关键字:async、await;kafka-python==1.4.2用到了关键字async,由此带来兼容性问题解决方案:升级kafka-python==1.4.4使用python3.6或以下版本  结论:尽量使用python比较稳定的版本,不要太新,因为很多插件还来不及适配;...

python的rsa公钥解密方法

示例:#-*-coding:UTF-8-*-importM2Cryptoimportbase64#私钥加密,公钥解密defpri_encrypt(msg,file_name):rsa_pri=M2Crypto.RSA.load_key(file_name)ctxt_pri=rsa_pri.private_encrypt...

python的单例模式:

python的单例模式:http://funhacks.net/2017/01/17/singleton/https://www.cnblogs.com/huchong/p/8244279.html#_labelTophttps://blog.csdn.net/weicao1990/article/details/79...
代码星球 ·2020-04-06

使用python type动态创建类

使用pythontype动态创建类X=type('X',(object,),dict(a=1)) #产生一个新的类型X和下列方法classX(object):   a=1效果相同,都创建一个继承object,具有属性a=1的类X...

python的日志模块:logging;django的日志系统;django日志输出时间修改

 Django的log,主要是复用Python标准库中的logging模块,在settings.py中进行配置  源代码 1、__init__.py包含以下类:StreamHandlerFormatter%(name)sNameofthelogger(loggingchannel...

kafak-python函数使用详解

 Consumer是非线程安全的Kafka只保证消息不漏,即atleaseonce,而不保证消息不重。关键点:假如consumer挂了重启,那它将从committedoffset位置(告诉server的消费的位置点)开始重新消费,而不是consumeoffset位置(真正的消费位置点)。这也就意味着有可能重复...

python2 和 python3兼容写法

一:使用ImportError,Python3中将一些Python2的模块名称做了修改,需要我们做一些处理来保证代码在不同Python版本中能够正常运行#-*-coding:utf-8-*-try:#Python3fromconfigparserimportConfigParserexceptImportError:#...
代码星球 ·2020-04-06

PyCharm中Python代码提示:Shadows name from outer scope

函数内部的变量,如果和函数被调用的外部的变量一样的话,就被PyCharm中叫做shadowsname这样的话,容易引发不容易觉察到的,由于函数内部和外部的变量名一致而引发的一些问题:比如:内部函数名引用时不小心写错了时,就会导致其实调用了外部变量名,从而导致逻辑错乱。所以解决办法是:确保函数内部和外部的变量名不要重复,...
首页上一页...318319320321322...下一页尾页