发布时间：2017-09-28 19:36:54
from kafka import KafkaConsumer# To consume latest messages and auto-commit offsetsconsumer = KafkaConsumer('my-topic', group_id='my-group', &n.........【阅读全文】
发布时间：2017-09-28 10:14:10
'中国' 中的ascii 字符码，而不是真正的中文。这是因为json.dumps 序列化时对中文默认使用的ascii编码.想输出真正的中文需要指定ensure_ascii=False：>>> import json>>> print json.dumps('中国')"\u4e2d\u56fd">>> print json.dumps('中国',ensure_ascii=False).........【阅读全文】
发布时间：2017-09-27 18:38:20
Redis和Memcached均支持对整数型Value值的增减，对应到具体命令中就是incr和decr命令。两个系统在这两个命令的具体语法上略有不同。Redis的incr命令语法分两种：1）incr key，即将指定主键key的value值加一；2）incrby key increment，即将指定主键key的value值加上increment。Redis的decr命令语法同样分为两种：1）decr .........【阅读全文】
发布时间：2017-09-27 17:22:59
当多个进程需要访问共享资源的时候，Lock可以用来避免访问的冲突。[python] copyimport multiprocessing import sys def worker_with(lock, f): .........【阅读全文】
发布时间：2017-09-05 21:09:46
问题：在实际业务中，拼接太多canal获取数据到kafka，导致大量数据丢失kafka默认参数情况下，以下数据，只有第一条和最后一条写kafka成功：Will send data into kafka , filename :mysql_log_bin.000002, end position:722590822, send json size : 925442Will send data into kafka , filename :mysql_log_bin.000002,.........【阅读全文】
