小编fac*_*cha的帖子

如何在匹配后的下一行显示?

grep -A1 'blah' logfile
Run Code Online (Sandbox Code Playgroud)

感谢这个命令对于每个包含'blah'的行,我得到包含'blah'的行的输出以及日志文件中的下一行.它可能是一个简单的但我无法找到一种方法来省略具有'blah'的行并且在输出中显示下一行.

awk grep sed

204
推荐指数
8
解决办法
22万
查看次数

python:如何在主程序结束时终止一个线程

如果我有一个无限循环的线程,有没有办法在主程序结束时终止它(例如,当我按Ctrl+ C)?

python multithreading python-multithreading

74
推荐指数
6
解决办法
14万
查看次数

Python中负数的模运算

我在Python中发现了一些关于负数的奇怪行为:

>>> -5 % 4
3
Run Code Online (Sandbox Code Playgroud)

谁能解释一下发生了什么?

python modulo negative-number

64
推荐指数
6
解决办法
5万
查看次数

python中的异步编程

python中是否存在异步编程的一般概念?我可以为一个函数分配一个回调函数,执行它并立即返回主程序流程,无论该函数的执行需要多长时间?

python asynchronous

57
推荐指数
4
解决办法
6万
查看次数

将int格式化为十六进制字符串

我需要从随机整数列表(0-255)创建一个十六进制数字字符串.每个十六进制数字应由两个字符表示:5 - "05",16 - "10"等.

例:

Input: [0,1,2,3,127,200,255], 
Output: 000102037fc8ff
Run Code Online (Sandbox Code Playgroud)

我设法提出:

#!/usr/bin/env python

def format_me(nums):
    result = ""
    for i in nums:
        if i <= 9:
            result += "0%x" % i
        else:
            result += "%x" % i
    return result

print format_me([0,1,2,3,127,200,255])
Run Code Online (Sandbox Code Playgroud)

但是,这看起来有点尴尬.有更简单的方法吗?

python formatting

47
推荐指数
7
解决办法
12万
查看次数

tmux:如何使用相同的键切换"on"和"off"选项

这是我的tmux.conf

cat tmux.conf
...
bind a set-window-option synchronize-panes on
bind b set-window-option synchronize-panes off
Run Code Online (Sandbox Code Playgroud)

如您所见,窗格的同步和非同步选项绑定到两个不同的键.是否可以使用相同的密钥切换同步/非同步?

tmux

44
推荐指数
2
解决办法
1万
查看次数

c:空隙大小*

我对C中的void*指针有点困惑.特别是在读完这个问题后:sizeof(某些指针)是否总是等于4?,一个人说没有保证sizeof(int*)== sizeof(double*)

我的问题是:是否有sizeof(void*)> = sizeof(任何其他指针类型)的保证?换句话说,我是否可以始终为void*指针指定some_type*指针,然后将其作为some_type*返回?

c void-pointers

23
推荐指数
2
解决办法
3万
查看次数

php curl:SSL_VERIFYPEER选项没有效果

我有这段代码用curl启动查询:

function curl_query($full_url, $username, $password, $payload) {
    $additionalHeaders = "";
    $process = curl_init($full_url);
    curl_setopt($process, CURLOPT_HTTPHEADER, array('Content-Type: application/x-www-form-urlencoded', $additionalHeaders));
    curl_setopt($process, CURLOPT_HEADER, 0);
    curl_setopt($process, CURLOPT_USERPWD, $username . ":" . $password);
    curl_setopt($process, CURLOPT_TIMEOUT, 30);
    curl_setopt($process, CURLOPT_POST, 1);
    curl_setopt($process, CURLOPT_POSTFIELDS, $payload);
    curl_setopt($process, CURLOPT_FOLLOWLOCATION, true);
    curl_setopt($process, CURLOPT_MAXREDIRS, 4);
    curl_setopt($process, CURLOPT_RETURNTRANSFER, TRUE);
    curl_setopt($process, CURLOPT_SSL_VERIFYPEER, FALSE);
    $return = curl_exec($process);
    if ($return === false) {
        error_log("CURL error ".curl_error($process));
    }
    return $return;
}
Run Code Online (Sandbox Code Playgroud)

选项CURLOPT_SSL_VERIFYPEER设置为false,因此我可以读取具有自签名证书的页面.但是,当我对https URL执行此代码时,我收到一个错误:

CURL error SSL: certificate subject name 'localhost' does not match target host name '192.168.1.1', …
Run Code Online (Sandbox Code Playgroud)

php ssl curl

13
推荐指数
1
解决办法
1万
查看次数

php:将变量内容下载为文件

主题可能吗?我有一个脚本正在执行.有一次,我在变量中有一大段文本.我是否可以将其作为可下载文件提供,而无需将可变内容写入磁盘?

<?php
    echo "Hello";
    //how do I make the content of this variable downloadable?
    $download_me = "download me...";
    echo "Bye";
?>
Run Code Online (Sandbox Code Playgroud)

php file attachment download

12
推荐指数
2
解决办法
2万
查看次数

Spark Streaming + Kafka:SparkException:无法找到Set的前导偏移

我正在尝试设置Spark Streaming以从Kafka队列获取消息.我收到以下错误:

py4j.protocol.Py4JJavaError: An error occurred while calling o30.createDirectStream.
: org.apache.spark.SparkException: java.nio.channels.ClosedChannelException
org.apache.spark.SparkException: Couldn't find leader offsets for Set([test-topic,0])
        at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:366)
        at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:366)
        at scala.util.Either.fold(Either.scala:97)
Run Code Online (Sandbox Code Playgroud)

这是我正在执行的代码(pyspark):

from pyspark.streaming import StreamingContext
from pyspark.streaming.kafka import KafkaUtils

directKafkaStream = KafkaUtils.createDirectStream(ssc, ["test-topic"], {"metadata.broker.list": "host.domain:9092"})

ssc.start()
ssc.awaitTermination()
Run Code Online (Sandbox Code Playgroud)

有几个类似的帖子有相同的错误.在所有情况下,原因都是空的kafka主题.我的"测试主题"中有消息.我可以把它们拿出去

kafka-console-consumer --zookeeper host.domain:2181 --topic test-topic --from-beginning --max-messages 100
Run Code Online (Sandbox Code Playgroud)

有谁知道可能是什么问题?

我正在使用:

  • Spark 1.5.2(apache)
  • 卡夫卡0.8.2.0 + kafka1.3.0(CDH 5.4.7)

apache-kafka apache-spark spark-streaming

12
推荐指数
2
解决办法
2万
查看次数