2回答
今年春天，我构建了一个Python应用程序，它的目的是继续运行，监控公共流，并收集有关特定主题的推文。代码运行得很好，但是现在当我想继续的时候，如果流没有几乎不断地收到tweet，我就会得到{ code : True}响应。我还没有弄清楚什么已经改变了，我应该做些什么来解决这个问题。
我正在使用660的Twitter库：和下面是我用于监视流的代码：
q = 'huuhkajat' # Comma-separated list of terms
print sys.stderr, 'Filtering the public timeline for track="
浏览 2提问于2014-09-30得票数 1
回答已采纳
1回答
我想做一些事情，比如更新进度条和实时处理的文件计数，但我不想让它跨越数百行。
具体来说，我正在处理大约6500封电子邮件，这需要几分钟的时间。我想打印出在不占用6500行的情况下已经处理了多少。
我在Python2中看到了一些解决方案，但在Python3中还不能解决这个问题。
浏览 7提问于2017-03-08得票数 1
回答已采纳
我有一个C#函数应用程序，它可以为每个客户端挑选多个文件和目录，并将这些数据上传到Azure Blob Storage。我有一个用Python编写的不同的Azure函数应用程序，它使用TimerTrigger从blob存储中拾取这些文件。为了实时处理这些文件，我希望让C#应用程序与Python应用程序进行通信。有没有可能让C#应用程序发布到超文本传输协议，并在Python应用程序中设置一个HttpTrigger，以便在文件准备好时对其进行处理？
浏览 27提问于2020-10-23得票数 0
回答已采纳
4回答
我需要编写代码来做一些实时处理，这是相当复杂的计算。我想创建一些Python类来管理我的所有脚本，并将算法的密集部分保留在C++中，以便它们可以尽可能快地运行。我想实例化Python语言中的对象，并使用Python语言中的回调函数将C++算法回调到脚本中。类似于：
myObject = MyObject()
myObject.setCallback(myCallback)
myObject.run()
def myCallback(val):
"""Do something with the value passed back to the python sc
浏览 2提问于2010-06-01得票数 6
回答已采纳
1回答
我正在使用下面的python代码来过滤所需的前缀和模式，但是由于存储桶中的文件量太大，显示结果的时间太长，并且web服务器超时，所以有任何方法可以加速这一过程。
my_list = []
my_bucket = s3.Bucket(bucket)
for line in my_bucket.objects.filter(Prefix=path):
if re.search(SourceFilePattern, line.key):
my_list.append(line.key)
浏览 7提问于2020-02-21得票数 0
1回答
我在做一个音频处理项目。我必须从麦克风中录制音频，并且必须实时处理这些样本。在执行记录过程时，我必须处理样本并回放它们。我正在使用下面的代码录制我的音频。
% Setting parameters
Fs = 44100;
nbits = 16;
dev_id = getfield(getfield(audiodevinfo, 'input'), 'ID');
% Creating the audiorecorder object
arec = audiorecorder(Fs, nbits, 2, dev_id);
display('Start spe
浏览 0提问于2014-11-22得票数 0
1回答
我一直试图用pocketsphinx进行语音识别，但我一直有一个奇怪的错误。我的代码如下
#!/usr/bin/env python
from os import environ, path
import pyaudio
from pocketsphinx.pocketsphinx import *
from sphinxbase.sphinxbase import *
MODELDIR = "pocketsphinx/model"
DATADIR = "pocketsphinx/test/data"
# Create a decoder with cer
浏览 4提问于2017-11-20得票数 0
回答已采纳
1回答
我正在通过TCP获取股票市场数据。我正在尝试使用Python连接到代理，例如，使用read_eager()通过Telnet (telnetlib)或者使用socket.recv()通过套接字连接。 输出如下所示： DE000XX6XP73;0.0000;2.44;G;2020-04-24;18:22:04.200'
';\r\nDE000XX9JX82;0.0000;0.0;G;2020-04-24;18:22:06.2'
'18;\r\nDE000XX9XXW3;0.0000;127.17;G;2020-04-24;18:22'
':21.9
浏览 21提问于2020-04-25得票数 0
回答已采纳
我已经编写了代码来从RabbitMQ队列中获取消息，并通过添加任务调度程序每5分钟执行一次该程序。
但是，这不是实时处理。它有5分钟的延迟。
我想让它实时处理。当有人在RabbitMQ队列中添加消息时，.NET程序应该立即选择它进行进一步处理。
任何指针都将不胜感激。
浏览 0提问于2020-01-02得票数 1
1回答
实时多目标监测
、、、
现在，我正在使用subprocess在后台运行一个长期运行的作业。由于多种原因(PyInstaller + AWS )，我不能再使用子进程了。
是否有一种简单的方法可以实现以下相同的目标？在多进程池(或其他什么地方)中运行一个长时间运行的python函数，并对stdout/stderr进行实时处理？
import subprocess
process = subprocess.Popen(
["python", "long-job.py"],
stdout=subprocess.PIPE,
stderr=subprocess.PIPE,
浏览 9提问于2022-10-14得票数 0
回答已采纳
1回答
我们有一个允许用户覆盖可选python回调函数的应用程序。
当接收到串行数据时，调用可选的用户定义的python函数：
def onDataReceived(bytes, timeStamp, address, peer):
return
这不是源文件，而是在应用程序中编译的。
请注意，应用程序是C++中的实时处理引擎，因此对cpython解释器的任何调用都会消耗相当多的开销。我确实可以访问预编译的函数，那么，是否有任何方法可以确定它是否像上面那样微不足道的空白/空，而不需要直接手工解析文本呢？
谢谢。
浏览 1提问于2016-03-22得票数 1
回答已采纳
1回答
我正在Raspberry Pi平台上通过Django/Python框架开发web应用程序，运行Debian和Python2.7.9。
我必须在Python脚本中使用多个线程来处理多个外围设备，如照相机和麦克风。这些外围设备必须实时处理。
我想知道为什么我可以在Python脚本中发出“导入线程”而不是“导入线程”(不管是PythonVersion2.x还是3.x)？
pi@raspberrypi:~ $ python --version
Python 2.7.9
pi@raspberrypi:~ $ python ./mythread.py
Traceback (most recent cal
浏览 3提问于2017-05-12得票数 0
回答已采纳
1回答
我有一个python + Scapy代码，用于嗅探数据包并测量它们的时间旅行。除了sniff()选项停止代码的运行之外，其他一切都运行得很好。
所以如果我有一个看起来像这样的代码：
print "hello"
print "world"
sniff(iface="lo")
print "this will not show"
因此，因为sniff正在运行，所以第4行将不会执行。
我怎样才能改变这一点？提前谢谢你！
浏览 1提问于2014-07-07得票数 1
1回答
我曾经在“风暴”和“星火”上工作过，但是桑扎还是很新的。
我不明白为什么Samza是在Storm已经在那里进行实时处理时被引入的。Spark在内存中提供了接近实时处理的功能，并具有其他非常有用的组件，如graphx和mllib。
Samza带来了哪些改进，还有哪些进一步改进的可能？
浏览 1提问于2017-03-29得票数 11
回答已采纳
2回答
EC2
、、
对于这个愚蠢的问题，我很抱歉，我刚开始从事云开发。我正在尝试开发一个云实时处理应用程序，它可以实时处理来自传感器的数据。数据流的数据速率很低，每个传感器都小于50 50Kbps。可能会有<10个传感器同时运行。
我很困惑，Amazon在这个应用程序中有什么用途？我可以直接使用EC2接收我的流并处理它。我为什么要动感？
浏览 3提问于2015-06-29得票数 0
回答已采纳
1回答
我看到了大数据队列作业，因为它们产生的数据很容易被消耗，所以它们对实时工作具有很好的性能。映射/减少作业(hadoop)的性能有不同的原因:它们是脱机的，允许大规模并行数据连接和聚合。
然而，我想知道，是否有任何用于大数据摄取的系统能够结合实时数据提要实现映射/减少样式的并行性?
具体来说，这意味着(在hadoop中)，允许读写和聚合尚未完成的“部分”输出文件。
浏览 5提问于2012-01-11得票数 1
2回答
我需要一个工具，它可以让我创建一个完全满足以下需求的解决方案：
需要具有交互性和用户友好性:应用过滤器的可能性，更改尺寸等。
需要在线更新:必须能够实时处理数据。
需要能够处理大量的数据和支持大数据技术。
python或R库的加分，但它绝对不是必须的。
我正在考虑开始使用D3py或谷歌图表，但我不知道它们是否是最好的选择。
你会推荐什么?为什么？
浏览 0提问于2017-09-05得票数 0
回答已采纳
1回答
正确避免读/写文件死锁
、、、
Python脚本创建子进程proc = subprocess.Popen()，该子进程每隔1秒向p.txt写入几行代码。我想在proc运行时实时处理此脚本中的p.txt更新。
...
def seek_file(file, process):
while process.poll() is None:
l = file.readline().strip()
if not l:
sleep(0.1)
continue
else:
yield tuple(l.split(
浏览 2提问于2015-11-21得票数 1
1回答
我想到了一个安卓应用程序，它依赖于我实时处理来自手机摄像头的图像(想想必须做的事情)。我想用Python在静态图像上运行我的算法原型，但我希望静态图像与通常从Android手机摄像头接收的格式相匹配(我不想为RGB制定一个可行的算法，然后找到Android的相机API给你HSV字节数组)。两个问题：
格式是什么？(或者至少是最常见的，因为Android的硬件是不同的)
如何在Linux上将jpg测试映像转换成这种格式？
浏览 3提问于2012-07-21得票数 1
回答已采纳
我在学弗林克。我对使用场景感到困惑。我们必须使用flink吗?与spring(web框架)应用程序有什么不同？例如，我想在过去的5分钟内统计一个网站的页面浏览量。我可以用弗林克的窗户数数。但是我可以先用springboot重新执行请求，然后保存到时间序列数据库中，然后导出一个sql来计数它。他们之间有什么不同？
在官方欺诈检测用例()中，我可以用flink的状态和窗口检测可疑事务。但是，我可以先使用springboot应用程序接收事务，然后将事务保存到时间序列数据库中，然后查询帐户中的所有事务，以发现可疑之处。他们之间有什么不同？是关于集群缩放的吗？我认为Springboot + kubern
浏览 6提问于2022-12-03得票数 2
1回答
在自然语言处理中，命名实体识别是识别命名实体的挑战，比如组织，地点，最重要的是名称。
这其中有一个主要的挑战，我称之为同义词:伯爵和德古拉实际上指的是同一个人，但这可能从来没有在案文中直接讨论过。
解决这些同义词的最佳算法是什么？
如果在任何基于Python的库中都有这方面的功能，我很想接受教育。我在用NLTK。
浏览 1提问于2013-04-05得票数 5
回答已采纳
3回答
如果我每隔几秒钟就有KBs的数据，那么是否使用带有Lambda函数的Kinesis来执行转换，并且使用Redshift作为目标，肯定比只做相同的操作更好，除了使用S3而不是Kinesis吗？我知道Kinesis是用于实时处理的，但是使用它是否有好处，而不仅仅是使用S3和将文件放入S3触发用于处理和存储到Redshift中的lambda函数？它们似乎是等价的，而不是与实时处理相关，而S3不是。
浏览 21提问于2022-10-01得票数 0
1回答
Linux中常见的SCHED_FIFO和SCHED_RR进程有哪些？用户输入是否属于实时处理的范畴？
浏览 1提问于2010-04-27得票数 7
回答已采纳
1回答
我是Apache的新手，我用python项目完成了一些基本的Kafka。大多数都遵循创建producer.py (将数据插入主题)和consumer.py (从订阅的主题读取数据)文件的相同模式。根据我的理解，这不是实时处理，因为生产者文件没有连续读取数据。
我想知道如何使用kafka+python进行实时数据流，在这种情况下，数据不断地被输入卡夫卡。(我认为一种方法是使用一个工作流工具，比如prefect或airflow，并每隔几分钟安排一次，想知道这是否是正确的方法。)
Ps:我正在做的项目有REST形式的数据源，每隔几分钟更新一次。如果您能指导我如何在这个场景中使用kafka+pytho
浏览 6提问于2022-08-10得票数 0
1回答
我使用的是一个第三方python模块，通常通过终端命令调用。当通过终端命令调用时，它有一个详细的选项，可以实时打印到终端。
然后，我有了另一个python程序，它通过子进程调用第三方程序。不幸的是，当通过子进程调用时，终端输出不再刷新，只在完成时才返回(该过程需要许多小时，因此我希望实时处理)。
我可以看到第三方模块的源代码，它不设置打印被刷新，如print('example', flush=True)。有没有办法迫使冲洗通过我的模块，而不编辑第三方的源代码？此外，我是否可以将此输出发送到日志文件(同样是实时的)？
谢谢你的帮助。
浏览 2提问于2019-07-22得票数 2
回答已采纳
我想将AWS的日志记录从CloudWatch移到Elk，使用ECS或Vm.All，我的Lambda函数在Python.To clarify中，我想摆脱CloudWatch，根本没有流到它。问:如何使AWS将日志推送到AWS任务或Vm而不是CloudWatch日志？
浏览 9提问于2022-09-20得票数 1
我想实时处理的视频，捕捉DJI使用机载NVidia Jetson模块。是否可以在外部设备中使用视频数据？如何访问它？
浏览 12提问于2022-11-14得票数 0
4回答
我有一些通过麦克风输入的音频。我把它录在“奥迪”里，它看上去像下面所示。
我想实时处理这个音频。我主要想做的是：
见实时音频振幅与时间图。
根据事件执行一些操作，比如，如果看到一个波形模式类似于某个预定义的波形，然后调用一个函数。
在图像的上半部分，你可以看到四个扰动。我希望每当看到这种干扰时，脚本应该调用一个函数，否则，当信号几乎是直的时候，不要继续分析信号。
是否有任何Python模块或C库允许我这样做？
浏览 1提问于2013-06-26得票数 7
1回答
存储和使用实时用户位置
、、、、
我的连接到一个Node.js服务器，我希望服务器能够实时获取用户的位置，并检查它是否接近不同的位置。
我被困在实时整合上了。位置部分类似于Lyft，其中用户(Lyft的驱动程序)位置是实时的，服务器可以按需访问以执行计算。
像Socket.io这样的websockets是解决方案吗?将用户的位置存储在MongoDb数据库中是一种更好的方法，还是完全不同的方法？
浏览 1提问于2022-07-26得票数 0
1回答
目前，据我所知，数据将从关系数据库排队到HDFS中。从那里，Pig或M/R可以运行与ETL相关的任务，并将转换后的数据放入HDFS的另一部分。然后，如果需要，可以删除原始数据。
有没有一种方法可以避免将原始数据导入HDFS，并在通过Sqoop传入的数据上运行PIG和M/R？这是怎么做的？
浏览 0提问于2013-12-14得票数 1
有没有像resque-web这样的东西可以用来做咖啡resque？我尝试将ruby版本的resque-web指向我的redis db，它似乎起作用了，但我的工作人员都没有注册，而且我只能在处理后看到摘要数据。
浏览 0提问于2011-12-21得票数 0
回答已采纳
我使用Raspberry Pi为LaserScanner(马达+ Rangefinder/Hokuyo)。
对于Rangefinder，我打开3个命令窗口，
#1 : roscore
#2 : rosrun urg_node urg_node _serial_port:=/dev/ttyACM0
#3 : sh /home/pi/hokuyo/lidarDemo.sh /home/pi/Desktop/Demo/Data lidar.txt
其中lidarDemo.sh：
if [$# -ne 2 ]
then
echo '2 inputs'
exit 1
fi
浏览 3提问于2020-07-16得票数 1
回答已采纳
1回答
我已经开始检查USERGRID作为我上一个项目的front+back end解决方案。实际上，我专注于评估这个框架的性能。我找不到任何有关如何处理到达服务器的REST请求的信息。他们在排队吗？如果是，是否可以配置其容量？
提前谢谢。
浏览 1提问于2014-06-13得票数 0
1回答
在我的组织里，我们试图用蜂箱或猪作为替代物。
主要目标:减少过程时间
NETEZZA处理时间: 90分钟
寻找结束过程:在30分钟内
过程是如何工作的：
进程即将维护增量history.There是两个表，history_table和new_table.History表维护总的历史记录，新的_table每天更新records.So，更新的记录被添加到历史记录中，table.Process有非常复杂的存储过程(Joins/删除/插入/更新)
同一进程正在应用于多个tables.Every历史表上，记录几乎有数十亿条。
我怀疑：
母猪/猪的表现比内特扎好吗？
UDF在单元格中是否是存储过程
浏览 1提问于2016-03-01得票数 1
1回答
我在不同的websockets (传感器数据-每月几个TBs )上输入了一些大容量数据，其中
我希望保证所有数据都存储在中，即使在高负载期间也是如此。
因此，我希望将数据分派到我的数据库和实时处理模块(例如GUI、ML预测等)，其方式是：
它缓冲的数据，以防所述模块的处理太慢，这样当负载减少时，这些模块就可以‘追赶’。
我尝试过的内容:带有队列(来自队列模块或线程模块)的 python线程，但是如果它阻塞了，我无法确保数据不会阻塞，如果它的非阻塞(例如asyncio.Queue)，我会得到竞争条件，事情就会崩溃。
所以，也许我应该使用某种回调方法，但我不知道该寻找什么。我希望问题不要太含糊。-
浏览 4提问于2021-02-01得票数 0
3回答
Yelp如何存储企业的时间信息，以及如何能够查询和过滤那些“现在就打开”的业务？它不需要一些实时处理，解析日期-日-时间信息，并比较它与“现在”。
浏览 0提问于2015-05-13得票数 2
回答已采纳
2回答
我需要每n分钟通过标签获取instagram帖子。我使用
好吧，但我不想每次都得到相同的帖子，我只想获取新的帖子。我想用一句话..保存下来，重复这一步。
但是API只允许这样的参数：
参数COUNT要返回的已标记介质的计数。min_tag_id返回此MIN_TAG_ID之前的媒体。此max_tag_id之后的MAX_TAG_ID返回媒体。
然后我想在请求中使用MIN_TAG_ID而不是Created_time，但是在api的响应json中找不到TAG_ID…(我可以通过TAG_ID进行过滤，但TAG_ID不会出现在响应中。不同寻常！！)
有什么想法吗？
浏览 1提问于2014-10-25得票数 0
2回答
特征库:实时处理
、、
我试图使用没有堆分配的Eigen来进行实时处理。
据我所知：
Matrix<double, Dynamic, Dynamic> allocates on the stack
Matrix<double, Dynamic, Dynamic, AutoAlign, 1, 1> allocates on the heap
and Matrix<double, 1, 1> allocates on the stack;
实时使用Eigen的一种方法是在启动时调整矩阵的大小，使其具有较大的大小，然后只使用此大小的一小部分。
我的问题是:对于像：Rm.colPivHou
浏览 4提问于2014-06-23得票数 0
我在下面写了一个简单的MATLAB程序来解调一个音频信号，这个音频信号之前已经用10000赫兹的载波频率进行了频率调制。该程序记录调频信号，将其存储在光盘上(供以后使用)，然后检索并解调它。现在，我希望能够在信号流入时连续解调(和显示)信号，而不必首先存储它。对如何修改下面的MATLAB代码有什么建议吗？
% FM Demodulate an Audio File June 5, 2018
%% Record the previously frequency-modulated signal for a few seconds.
Fs = 44100; % Sample frequency
浏览 0提问于2018-06-06得票数 1
2回答
有没有人实现了的DIRAC2库，用于在iPhone上进行实时音高校正？这个库似乎不支持实时处理，但也许有人已经这样做了？
Thx
浏览 1提问于2010-06-05得票数 0
回答已采纳
1回答
服务器端输出的实时读取
、、、
我正试图从服务器上的相机中处理图像，并在本地机器上实时处理后获取信息。我可以在我的服务器上作为终端输出获得必要的信息，但是在我的服务器程序运行之前，我不能将这些信息放在本地机器上的python代码中。我受够了这个密码：
cmd="sshpass -p 'pass' ssh -Y user@ip -t 'process_image; bash -l'"
p = subprocess.Popen(cmd, stdout=subprocess.PIPE, bufsize=1)
for line in iter(p.stdout.readline, b&
浏览 6提问于2017-01-28得票数 0
回答已采纳
1回答
我正在使用FFmpeg进行视频解码。当我尝试解码一个以特定fps (例如: fps=25)的h265编码的视频时，结果是一个解码的视频，但却是一个不同的fps。即使我有很高的错失率或丢帧，我如何才能以精确的fps=25解码视频？我使用以下命令进行解码: ffmpeg -benchmark -i -f null /dev/null
我在包含8个内核的Odroid-XU3板上运行上述命令。操作系统为Ubuntu 14.04 LTS。
请不要客气，任何帮助都欢迎。提前谢谢你。
浏览 0提问于2018-05-31得票数 1
2回答
ExtJS 4实时本地化
、、、
我想知道是否有人可以指导我如何在extjs4中管理本地化。我想知道是否有方法可以在不需要刷新页面的情况下实时处理语言更改。
提前谢谢。
浏览 1提问于2012-01-31得票数 0
1回答
我已经使用Java Sound API构建了一个应用程序，该应用程序能够录制和播放语音，程序在录制完成后显示录制的语音的波形。我想在录制完成的同时显示波形。有没有人能推荐一种方法或java库来实现这一点？
非常感谢。
浏览 0提问于2011-03-14得票数 4
我想使用dbo: leader向DBpedia实时端点的DBpedia查询资源United States (例如，(dbr:Barack_Obama dbr:John_Roberts dbr:Joe_Biden dbr:Paul_Ryan ))。但是，我从DBpedia live获得过期的值。
浏览 9提问于2019-06-21得票数 0
是否有让Fiware-cepheus接受多个配置文件，因为我不想发送不同的数据类型，我想实时处理它，但不能安装不同的Cepheus Vm到每个数据联合，有一种方法可以让Cepheus采取不同的配置文件
浏览 1提问于2017-05-01得票数 1
回答已采纳
1回答
带计数器的音频分类
、、、、
我试图建立一个模型，它可以识别一个特定的声音，每次它听到这个声音，它就会增加一个计数器1。例如，如果它听到一只特定的鸟啁啾十次，计数器应该显示数字10。
我在这里找一些关于如何做这件事的指导。我知道我需要使用音频分类，对于我的数据，我只有一个特定声音的.wav文件，因为我用我的iPhone记录了它们。目前，我只是对数据进行预处理，并使用Python中的librosa进行一些EDA。
，这是我的问题：
1.是否有一种方法可以根据我所拥有的数据来训练一个模型来识别一个特定的声音？(如果它听到任何不同的消息，它被归类为0/否)
2.我将如何将音频分类模型(假设它可以工作)与一个计数器结合起来，该计数
浏览 0提问于2021-12-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
