小编jaw*_*wwe的帖子

python脚本中的ffmpeg

我想在python脚本中运行以下命令,我还想让它循环遍历文件夹中的几个视频.这是我想要运行的命令.

ffmpeg -i mymovie.avi -f image2 -vf fps=fps=1 output%d.png

我希望适合这样的事情:

import ffmpy
import os

path = './Videos/MyVideos/'
for filename in os.listdir(path):
    name = filename.replace('.avi','')
    os.mkdir(os.path.join(path,name))
    *ffmpeg command here*
Run Code Online (Sandbox Code Playgroud)

我找到了一个名为ffmpy的ffmpeg包装器,这可能是一个解决方案吗?

python ffmpeg video-processing

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

消息中心上的Kafka Streams KTable配置错误

现在可以在Message Hub上解决此问题

我在Kafka中创建KTable时遇到了一些麻烦。我是Kafka的新手,这可能是我问题的根源,但我仍然想在这里提问。我有一个项目,我想通过计算它们的总出现次数来跟踪不同的ID。我正在使用IBM Cloud上的Message Hub来管理我的主题,到目前为止,它的工作非常出色。

我在Message Hub上有一个主题,它产生的消息如{"ID":"123","TIMESTAMP":"1525339553", "BALANCE":"100", "AMOUNT":"4"},到目前为止,唯一相关的键是ID。

我的Kafka代码以及Streams配置如下所示:

import org.apache.kafka.streams.StreamsConfig;

Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, appId);
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
props.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, "3");    
props.put("security.protocol","SASL_SSL");
props.put("sasl.mechanism","PLAIN");
props.put("ssl.protocol","TLSv1.2");
props.put("ssl.enabled.protocols","TLSv1.2");
String saslJaasConfig = "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"USERNAME\" password=\"PASSWORD\";";
saslJaasConfig = saslJaasConfig.replace("USERNAME", user).replace("PASSWORD", password);
props.put("sasl.jaas.config",saslJaasConfig);

StreamsBuilder builder = new StreamsBuilder();

KStream<String, String> Kstreams = builder.stream(myTopic);

KTable<String, Long> eventCount = Kstreams
        .flatMapValues(value -> getID(value)) //function that retrieves the ID
        .groupBy((key, value) -> value)
        .count();
Run Code Online (Sandbox Code Playgroud)

运行代码时,出现以下错误:

线程“ KTableTest-e2062d11-0b30-4ed0-82b0-00d83dcd9366-> StreamThread-1”中的异常org.apache.kafka.streams.errors.StreamsException:无法创建主题KTableTest-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition …

java apache-kafka message-hub apache-kafka-streams ibm-cloud

5
推荐指数
1
解决办法
431
查看次数

在对象上使用.map()从不同的父键获取值

我正在使用nodeJS,并调用object了以下包含以下内容的对象:

{ first:
    { bool: false,
      date: '2018-07-15' },
  second:
    { bool: false,
      date: '2019-08-05' },
  third:
    { bool: false,
      date: '2019-09-02' } 
}
Run Code Online (Sandbox Code Playgroud)

我想要得到的bool,从价值firstsecondthird。有没有办法做到这一点.map()

提取键firstsecondthirdobject我的理解使用Object.keys(object),但如何继续.map()挖掘得到所有三个价值bool

javascript node.js

0
推荐指数
1
解决办法
33
查看次数