我想在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包装器,这可能是一个解决方案吗?
现在可以在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
我正在使用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,从价值first,second和third。有没有办法做到这一点.map()?
提取键first,second并third从object我的理解使用Object.keys(object),但如何继续.map()挖掘得到所有三个价值bool?
apache-kafka ×1
ffmpeg ×1
ibm-cloud ×1
java ×1
javascript ×1
message-hub ×1
node.js ×1
python ×1