小编pan*_*ish的帖子

我有以下程序可以使用所有发送到Kafka的消息。

from kafka import KafkaConsumer

consumer = KafkaConsumer('my_test_topic',
                         group_id='my-group',
                         bootstrap_servers=['my_kafka:9092'])
for message in consumer:
    consumer.commit()
    print ("%s key=%s value=%s" % (message.topic,message.key,
                                          message.value))
KafkaConsumer.close()

使用以上程序，我可以使用所有发送到Kafka的消息。但是，一旦所有消息都消耗掉了，我想关闭没有发生的kafka用户。我同样需要帮助。

我--dryrun和我的pybot命令一起使用了; 我想知道它在testcase或库中的确切含义.

我想将ipv6地址的简写符号转换为ipv6寻址格式的简写符号; 我知道我们可以使用ipaddress库对ip地址执行各种操作.例如,我想转换::abc:7:def为0000:0000:0000:0000:0000:0abc:0007:0def.

我在python中为进度条编写了一个小程序.但是这个程序总是达到99%.始终存在1%的不准确度.以下是我的代码.

import time
import sys

for i in range(100):
    time.sleep(1)
    sys.stdout.write("\r%d%%" % i)
    percent = float(i)/100
    hashes = '#' * int(percent * 50)
    spaces = '-' * (50 - len(hashes))
    sys.stdout.write("\rPercent: [{0}] {1}%".format(hashes + spaces, int(percent * 100)))
    sys.stdout.flush()

在上述程序中,始终存在1%的不准确度.如果我将范围取为100然后计算%; 我的进度条保持在99%,如果范围是50,我的进度条保持在98%.任何人都可以告诉我,如果我在做错了吗？

我正在尝试为我们的一个要求创建一个JSON,我想在我的Tcl脚本中进行JSON marshelling,有没有办法在Tcl中做同样的事情.任何带有示例的解决方案都会更有用.

I want to create multiline logger using python logging module. When I use the code snippet below to format logger:

import logging
logger = logging.getLogger(file_name)
logger.setLevel(logging.DEBUG)
ch = logging.StreamHandler()
ch.setLevel(logging.DEBUG)
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
ch.setFormatter(formatter)
logger.addHandler(ch)

I get the output below for multiline logs when I use logger.info("""line 1\nline 2\n line 3""")

2017-07-20 13:21:14,754 - my_logger.py - INFO - line 1
line 2
line 3

I want my output as below:

2017-07-20 13:21:14,754 - my_logger.py …