我是坦索弗洛的新手，我遇到了一个问题。当我的程序到达x_batch = sess.run(X_mb)时，它被卡住了(所以，它可以打印1和2，但不能打印4，我猜它是一个没完没了的循环)。我打印X_mb的值，结果是Tensor("batch:0", shape=(32, 39), dtype=float32)。谁能帮我吗? Thx！mb_size = 32，g的形状是60366，39。
经修订的守则：
X = tf.placeholder(tf.float32, shape=[None, X_dim])
def sample_z(m, n):
return np.rand
浏览 8提问于2017-09-16得票数 1
回答已采纳
我有一个应用程序，我在队列中填入大量数据，然后工作人员清空这些数据。
我使用队列是因为它被阻塞了，所以我不需要一直应用锁。
所以有时候队列里塞满了一百万条字符串数据。每个项目占用大约80字节的存储器。
在某些情况下，在使用高峰期，python开始占用大约3 GB的内存。然后，当使用者清空整个队列时，python仍然占用3 GB的内存。我正在使用ps命令检查内存。这是什么现象？这种高内存使用率是不是首先是由于队列膨胀造成的？如果是这样，那么可以做些什么来控制它呢？在python中有没有其他更好的集合来代替queue呢？
浏览 2提问于2013-01-04得票数 4
1回答
我有一个非常简单的脚本，它在tensorflow中获取一个图像，对其进行解码，然后尝试将该张量存储为一个numpy数组。但是，在下面的当前代码中，tensorflow在评估会话中的张量时无限期地挂起。
import tensorflow as tf
result = 0
#Get image into appropriately sized tensor
filename_queue =
tf.train.string_input_producer(['C:\Python3\TensorflowExp\Pokemon_data\filename0.jpg'])
read
浏览 0提问于2018-10-30得票数 1
回答已采纳
我有一个python瓶子应用程序，它使用线程。由于我使用的是，线程正在阻止应用程序的执行(一个从线程中触发的对话框正在阻止瓶子路径响应到客户端，直到被拒绝)。
这里的一项研究表明，我应该使用猴子补丁，而不是试图修补线程：
# Patch python's threads with greenlets
from gevent import monkey
monkey.patch_all(thread=False)
这并不妨碍我编写的最小。
但是，在大量使用线程时，使用像threading.setEvent()这样的方法会引发这些错误
这是我得到的错误：
C:\Users\IEUser\d
浏览 3提问于2013-05-13得票数 3
我使用TensorFlow python创建了一个模型。现在，我已经在C++中加载了模型，并使用session->Run (提供输入张量)运行它。代码被很好地编译和链接，但是一旦它到达会话->在运行时运行，它就不会继续，也不会产生任何错误消息！它看起来像是永远在运行！我还检查了CPU使用率，但它也没有显示任何密集的计算！
浏览 3提问于2016-02-12得票数 2
我正在工作的项目，需要控制发送队列的代码。所以我很好奇是否有人使用python/django代码在rabbitmq中创建队列？:)
浏览 1提问于2011-10-12得票数 1
回答已采纳
我环顾了一下，但我似乎解决不了这个问题。我想在我的django应用程序的视图中执行python脚本。我将想要执行的代码放在一个django管理命令中，这样就可以通过命令行python manage.py command-name访问它。然后，我尝试使用subprocess.Popen("python manage.py command-name",shell=True)运行此命令。
但是，此命令可能需要一些时间才能执行，因此我希望视图继续，并允许脚本在后台执行。单独使用subprocess.Popen似乎会导致视图挂起，直到脚本完成，所以我尝试使用线程(遵循 SA问题)：
cl
浏览 0提问于2010-06-30得票数 6
回答已采纳
我有一种情况，我下载了很多文件。现在一切都运行在一个Python主线程上，每隔几分钟就会下载多达3000个文件。问题是这样做所需的时间太长了。我知道Python没有真正的多线程，但是有没有更好的方法呢？我在考虑启动多线程，因为I/O限制的操作不应该需要访问全局解释器锁，但可能我误解了这个概念。
浏览 2提问于2010-06-04得票数 10
回答已采纳
1回答
如何在multiprocessing上使用root.mainloop？我正在使用Python3.6。我需要在它之后执行代码行，有些代码需要对象。
我不想创建第二个对象，就像我的问题所建议的其他一些答案一样。下面是一个小代码片段(设置为JSON对象)：
from multiprocessing import Process
def check():
try: sett['setup']
except KeyError:
sett['troubleshoot_file']=None
check()
else:
浏览 2提问于2017-09-09得票数 1
回答已采纳
以下代码是.mat文件的批处理数据提供程序，但在运行它时有以下问题：
TypeError: expected str, bytes or os.PathLike object, not FIFOQueue
守则是：
import numpy as np
import tensorflow as tf
from tensorflow.python.framework import ops
from tensorflow.python.framework import dtypes
import h5py
def Reader(filena
浏览 9提问于2017-07-21得票数 4
回答已采纳
我有一个Scrapy多级蜘蛛，它在本地工作，但是在每次请求时在云中返回GeneratorExit。
下面是解析方法：
def parse(self, response):
results = list(response.css(".list-group li a::attr(href)"))
for c in results:
meta = {}
for key in response.meta.keys():
meta[key] = response.meta[key]
yield res
浏览 1提问于2018-04-04得票数 1
回答已采纳
1回答
所以我的代码是：
with tf.Session() as sess:
init.run()
epoch = 1
iteration = 1
print("Checkpoint 1")
X_batch, y_batch = tf.train.batch([X_train, y_train], batch_size=batch_size)
print("Checkpoint 2")
X = X_batch.eval()
y = X_batch.eval()
print("Che
浏览 1提问于2017-06-15得票数 2
回答已采纳
这段简单的代码在几秒钟(大约5秒)后崩溃(窗口没有响应)。
import pygame
from pygame.locals import *
pygame.init()
screen = pygame.display.set_mode((640, 480), 0, 24)
#clock = pygame.time.Clock()
#font = pygame.font.Font(None, 32)
cycles = 0
while True:
screen.fill(0)
# text = font.render('Cycles : %d' % cycle
浏览 0提问于2013-11-24得票数 15
回答已采纳
我不确定这是否是问这个问题的正确领域，老实说，我不知道如何表达这个问题，因为我不知道我在想什么。
我正试图找出一种更好的方法，从OnPre前提SQL Server数据库中触发第三方API调用。目前，有一个Python脚本正在运行，根据Python条件从SQL服务器获取信息，它将到达API端点。此过程允许我工作的公司通过API添加、取消和更新第三方供应商的个人信息。
我手动运行Python脚本。我可以把这个脚本放到作业调度程序中，比如cronjobs。是否有一种方法可以“侦听”Server中的某种类型的更新，触发Python脚本来运行某个API调用？是否可以根据发送到Server的更新类型，将P
浏览 0提问于2023-01-02得票数 0
2回答
我有一个文本文件(例如，"X")存储在GCS上，并由GCS客户端库创建和更新。我使用GAE Python。在我的网站用户每次添加一些数据时，我都会在“默认”队列中添加一个任务(taskqueue.Task)来执行一些操作，包括修改文件("X")。
有时，日志中会出现以下错误：
E 2014-07-20 03:19:06.238 500 3KB 430ms /t
0.1.0.2 - - [19/Jul/2014:14:49:06 -0700] "POST /t HTTP/1.1" 500 2569 "http://www.myappdoma
浏览 0提问于2014-07-20得票数 1
回答已采纳
2回答
我正在尝试将一些数学表达式排入python中，最后我想给出它们的求和。
我正在尝试这样做：
for i in range(0, n-1): sum_queue(pow(-1,i)/((2*i)+1))
print(sum(0)) #or sum("latest")
有可能吗？
浏览 3提问于2014-03-02得票数 0
我正在寻找一个可以将任务分布在几个服务器上的Python库。该任务将类似于可以由subprocess库在一台机器中进行并行处理的任务。
我知道我可以为这些目的设置一个Hadoop系统。然而，Hadoop是很重的。在我的例子中，我希望使用共享网络磁盘进行数据I/O，并且我不需要任何花哨的故障恢复。在MapReduce的术语中，我只需要映射器，不需要聚合器或减速器。
在Python中有这样的库吗？谢谢!
浏览 2提问于2013-07-22得票数 1
我正在尝试确定将collections.deque对象转换为python列表对象的复杂度为O(n)。我想它必须获取每个元素并将其转换为列表，但我似乎找不到deque背后的实现代码。那么，Python是否在幕后构建了一些更高效的东西，可以将O(1)转换为列表？
编辑:基于以下内容，我认为它不会比O(n)更快。“索引访问在两端都是O(1)，但在中间会减慢到O(n)。对于快速随机访问，请使用列表。”
如果它不能在O(1)时间内访问中间节点，它将无法在没有相同复杂性的情况下进行转换。
浏览 3提问于2018-09-19得票数 4
我想问一下，如果有时需要cp、mv或启动一些python文件的exec或shell_exec函数，那么使用/etc/sudoers处理www数据的最佳或最聪明的方法是什么。www-data ALL=(ALL) NOPASSWD:这是唯一的方法，或者你将如何配置这样的问题？thx
浏览 8提问于2022-01-07得票数 1
回答已采纳
1回答
执行SQL查询时执行脚本
、、、
当在MySQL数据库上执行update查询时，我想执行脚本(可能是用python编写的)。查询将从我无权访问的用PHP编写的外部系统执行，因此我无法编辑源代码。MySQL服务器安装在我们的机器上。你知道我如何才能做到这一点吗，或者说这是可能的吗？
浏览 12提问于2016-08-31得票数 1
回答已采纳
1回答
有没有可能在python中控制线程的比例执行时间。例如，我的程序中有三个函数F1、F2和F3。我在python中使用start_new_thread调用每个函数。我希望F2线程执行70 %的时间，而F1和F3应该共享30 %的剩余时间。有没有一种方法可以明确地控制这些时间。
浏览 1提问于2013-06-03得票数 2
我将遵循本教程：
当队列中有东西时，我如何分配我的20个工作进程中的一个来处理它？
我使用的是Python。
浏览 12提问于2010-11-14得票数 14
回答已采纳
在尝试使用python的大容量API索引大约20000条记录(每条记录的大小约为100 mb )时，我看到最大写入队列大小为6。下面我对批量索引正确(默认配置为500块和100 mb块大小)的理解是正确的吗？
Bulk API将向ES发送40个请求(20000/500个)。每个大容量请求都被原子地持久化，即所有500个块或没有。如果活动线程繁忙，则大容量请求将作为一个整体对象池在写队列中。
浏览 8提问于2021-03-22得票数 0
回答已采纳
3回答
我正在尝试构建我的系统的接收端，它通过千兆以太网链路发送UDP数据段。到目前为止，我已经尝试了Matlab和Python，但这两种解决方案似乎都不是很有效。我总是遇到巨大的丢包率，这不能用UDP不可靠的事实来解释。我认为我没有足够快地读取传入的缓冲区，因此新的帧被丢弃。
我的问题是，C/C++实现会比Matlab和Python更快吗？
那么线程呢？这会改善情况吗？我在考虑生产者/消费者方案。一个线程用于处理UDP套接字，另一个线程用于处理传入的段。然而，我仍然对此有一些怀疑。例如，如果我使用互斥锁，这意味着生产者不能在消费者从队列中读取数据时写入队列。这意味着生产者仍然会被消费者的操作所拖累。
浏览 1提问于2012-06-01得票数 1
我对python语言很陌生，请在这一点上与我保持一致。
我想在两个单独的线程中运行两个状态机，通过队列相互通信。我使用包创建状态机。
我的理解是，执行操作的所有操作/代码都必须隐藏在事务中。
这些行取自转换包的示例，显示了将代码放在何处进行转换。
# escapades. Because the legal department says so.
self.machine.add_transition('complete_mission', 'saving the world', 'sweaty',
浏览 5提问于2015-05-27得票数 5
回答已采纳
1回答
好吧，我必须要问这个。
当我使用shell_exec，exec或其他命令从php中执行python代码时，我的页面加载速度慢了10倍。因此，即使在我的本地主机中，使用exec或system函数加载空页面也需要大约0.01秒，而在正常情况下，这个时间大约是0.001秒。当我尝试完成我的任务时，我觉得python更舒服(一个html解析器，根据我的需要提取信息，找到最递归的单词，索引它们等等) 1.然而，这些函数的缓慢让我重新考虑用php重写相同的类。有没有其他有效的方法从php执行python？
*1我更喜欢写自己的类，而不是第三方解析器，因为它们根本不能满足我的需求。
浏览 2提问于2011-10-25得票数 0
TensorFlow有CIFAR-10教程，其中.Python 中的源代码。
它有，用于从二进制文件中读取示例。
我不明白它是怎么工作的。怀疑这在某种程度上与TensorFlow延迟性质有关，但不知道怎么回事。
在某些情况下，例程执行以下操作：
# Read a record, getting filenames from the filename_queue. No
# header or footer in the CIFAR-10 format, so we leave header_bytes
# and footer_bytes at their default of 0.
浏览 3提问于2016-01-27得票数 0
回答已采纳
1回答
我使用urllib2下载相对较大的文件(每个10MB)，然后将其作为json文件加载，并将数据插入到mysql数据库中，然后在无限循环中重复此过程。下载大约需要一分钟，然后将所有内容加载到mysql中。有没有办法创建一个线程，当主线程使用python插入到mysql中时进行下载？
我的伪代码：
while 1:
download file with urllib2
decode as json file
extract data I want
do some computations on data
insert data into mysql
非常感谢!
浏览 2提问于2012-01-19得票数 2
回答已采纳
我有一个数据产品，它接收车辆的实时数据流，处理信息，然后通过rest APIS显示它。我希望重建ETL方面的系统，以提高可靠性和架构顺序。我正在考虑使用Apache Airflow，但有一些疑问。
我需要编排的python微服务很复杂，并且有许多不同的依赖项，因此，如果在Airflow中使用python操作符实现，那么整体解决方案将是巨大而棘手的。您是否看到了使用Airflow来满足这些需求的任何方便的选择？使用Kafka或任何其他消息传递系统可能是更好的解决方案？
谢谢
浏览 0提问于2020-06-13得票数 0
有一个问题是，它询问了gevent.queue.Queue的必要性，因为它没有并行性，而只是与gevent并发。正确地说，答案解释如下：
..。您可能希望确保一系列语句以原子方式执行..。
因此，每个方法都应该是原子的，这解释了为什么我们需要一个队列对象，而不是一个“常规”列表，例如。但是，根据Python ，queue.Queue对象已经具有这些安全特性：
当必须在多个线程之间安全地交换信息时，它在线程编程中特别有用。本模块中的队列类实现了所有所需的锁定语义。
那么，当gevent.queue.Queue已经存在时，为什么会存在queue.Queue呢？是否需要更多的安全特性
浏览 0提问于2019-06-25得票数 0
回答已采纳
关于如何从客户端执行Python脚本，有许多答案。我想知道是否可以从服务器端执行脚本，并检查执行是否成功完成。假设我使用的是Python堆栈，它在两端都使用JavaScript，并且有一堆脚本任务需要从后端触发。
浏览 0提问于2013-08-29得票数 2
2回答
我使用SQS作为我的系统中的“桥”，它接收来自GAE的任务，并将在EC2上进行处理。目前，我能够从GAE中将任务添加到这个队列中，但在如何在EC2上使用这些任务方面遇到了一些困难。所以我的问题是：
在EC2上构建任务使用者(基于python)的推荐方法是什么，这将监视SQS并为工作分配新的入站作业？
AWS有这种类型的SQS监控产品吗？如果不是，Celery的period task是一个很好的候选人吗？
浏览 2提问于2014-02-14得票数 0
我有一个场景，在文档上有一个数组字段，我们试图在每个文档上更新该数组中的一个键/值，因此，例如，一个文档应该如下所示：
_source:{
"type": 1,
"items": [
{"item1": "value1"},
{"item2": "value2"}
]
}
我们试图有效地更新"value1“(例如，在每个”type“文档中)：1.我们希望避免冲突，我们希望能够通过使用纸条(最好是在python中)来实现这一切，但我找不到如何更新pyt
浏览 1提问于2016-04-19得票数 1
回答已采纳
我使用的是Python Flask框架。
我需要使用python的多处理模块。基本上，我希望在单独的微处理器中运行每个作业。
这是我的代码
import multiprocessing
def indexFindSubscriber(self):
jobs = []
for idx, val in enumerate(allNetworks):
print("index is %d and value is %s" % (idx, val['ip']))
process = multiprocessing.P
浏览 7提问于2020-03-05得票数 0
3回答
我们正在从生产数据库中迁移一些数据，并希望将大部分数据存档在Cloud中。
最终，我们将把所有的数据都移到那里，不过最初我们会把重点放在作为测试的归档数据上。
我们选择的语言是Python，并且能够逐行将数据从mysql传输到数据存储。
我们大约有1.2亿行要传输，一次一行的方法需要很长的时间。
有没有人发现过关于如何使用python将数据批量插入云数据存储的文档或示例？
如有任何意见、建议，敬请见谅。
浏览 2提问于2015-08-31得票数 6
回答已采纳
1回答
因此，我尝试将阻塞内容从web请求转移到后台任务，并利用队列。我也是消息传递和pub/sub的新手。用户将数据推送到那里，数据会被处理，然后用户会收到通知。我为此做了一个芹菜设置，发现它不能满足我的用例，即每个用户都有自己的任务的私有队列。 我尝试指定在worker派生期间创建丢失的队列(发送队列名称，用逗号分隔)，并将它们列在队列设置中，就像之前在internet上回答“用芹菜动态创建队列”时所说的那样。它创建队列，但当我在设置和命令行中指定的队列名称与指定的名称不同时，它不会创建队列。解决方案是产生更多具有队列名称的工作进程，这不能满足用例，因为将有数百万个数据处理请求。 我发现pyth
浏览 30提问于2019-04-16得票数 1
回答已采纳
3回答
有没有消息传递解决方案(最好支持Python)，我可以像邮箱一样使用，例如，从任何给定的队列中检索消息，而不必订阅？我认为消息队列可以工作，但我必须重复订阅，从队列中抓取消息，然后取消订阅，这听起来并不是最优的。
浏览 1提问于2011-03-30得票数 0
回答已采纳
我有以下代码：
from multiprocessing import Process, Manager, Event
manager = Manager()
shared_Queue = manager.Queue(10)
ev = Event()
def do_this(shared_queue, ev):
while not ev.is_set():
if not shared_Queue.__getattribute__('empty')():
item = shared_queue.get()
p
浏览 0提问于2017-09-05得票数 0
1回答
我以前没有做过太多的线程。我对它的工作原理的假设如下：
启动n个线程
当一个线程结束时，启动一个新的线程并终止现有的线程。这样合适吗？
我正在使用python，所以我打算让我的线程中的main方法在它死之前创建一个新的实例。我不能完全确定这是否安全。有什么建议吗？
浏览 0提问于2012-12-09得票数 2
2回答
多处理队列满
、、、
我使用concurrent.futures来实现多处理。我得到了一个queue.Full错误，这是奇怪的，因为我只分配10个作业。
A_list = [np.random.rand(2000, 2000) for i in range(10)]
with ProcessPoolExecutor() as pool:
pool.map(np.linalg.svd, A_list)
错误：
Exception in thread Thread-9:
Traceback (most recent call last):
File "/Library/Frameworks/Pyt
浏览 5提问于2015-07-22得票数 16
1回答
我正在寻找一种在Python中的多线程之间传递值(例如整数、数组)的方法。我知道这个任务可以通过使用Queue模块来完成，但是我对python和这个特定的模块都不是很熟悉。
我有以下场景:每个线程需要根据自己的数据或来自其他线程的数据进行一些计算。此外，每个线程都知道哪些其他线程持有特定作业所需的数据(所有线程都有一个包含所有线程的数组，因此任何线程都知道，对于任务X，他需要从该数组中的特定线程(行、列)获取数据)。
如何使用队列模块或其他技术(队列模块似乎适合这项工作)来完成线程之间的通信。任何帮助都是非常感谢的。非常感谢。
浏览 0提问于2013-03-20得票数 2
回答已采纳
我知道您可以在仪表板或开发服务器控制台中查看当前排队和运行的任务。但是，有没有办法以编程方式获取该列表？文档只描述了如何将任务添加到队列中，而没有描述如何列出和/或取消它们。
请给我python的。
浏览 0提问于2010-10-23得票数 6
回答已采纳
1回答
我正在使用Python中的Amazon的SQS实现发送和接收消息--我所做的一切使我的代码接收端检索我发送的消息，我做错了什么？
send.py：
SESSIONS_ACCESS_KEY = "************"
SESSIONS_SECRET_KEY = "************"
sess = boto3.session.Session(aws_access_key_id=SESSIONS_ACCESS_KEY, aws_secret_access_key=SESSIONS_SECRET_KEY, region_name='eu-cent
浏览 0提问于2020-08-13得票数 2
回答已采纳
这是一个网络挖掘脚本。
def printer(q,missing):
while 1:
tmpurl=q.get()
try:
image=urllib2.urlopen(tmpurl).read()
except httplib.HTTPException:
missing.put(tmpurl)
continue
wf=open(tmpurl[-35:]+".jpg","wb")
wf.write(
浏览 3提问于2012-08-13得票数 8
是否可以使用RabbitMQ和Python进行基于内容的路由？
AMQP标准和RabbitMQ声称支持基于内容的路由，但是Python库是否支持指定基于内容的绑定等？
我目前使用的库(py-amqplib )似乎只支持基于主题的路由和简单的模式匹配(#，*)。
浏览 3提问于2010-07-19得票数 11
回答已采纳
考虑一层N个订阅者，所有订阅者都使用相同的队列名称和路由键值连接到直接交换。这创建了一个负载平衡系统，其中以循环方式将入站消息发送给1个订阅者。这对于处理横向扩展问题非常有效，因为随着负载的增加，可以添加更多的订阅者，如果需要，可以在以后撤回订阅者。
现在考虑能够向该层中的所有订阅者发送消息的要求，而不需要知道有多少订阅者(例如，“重置状态”或“立即关机”管理消息)。有没有办法在rabbitmq中做到这一点？如果这不可能，有没有更好的方法？
我的环境是使用amqplib的Python。
浏览 2提问于2010-07-01得票数 0
回答已采纳
2回答
日安。在Python3.6.5中，我使用的是Python。这是我的密码：
if event.type == pygame.KEYDOWN:
if pygame.key == pygame.K_UP:
my_change = -15
my += my_change
pygame.display.update()
clock.tick(24)
我的问题是，当我加上
running = True
while running:
到该代码的顶部，然后运行它，我的窗口就会停止响应，尽管我只添加了2行代码！
记者:我还没有破译的密
浏览 0提问于2018-10-01得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
