我正在尝试在我的测试项目中设置django管道，但是，我遇到了一个没有明显解决方案的bug。下面是settings.py中的管道配置
PIPELINE = {
'PIPELINE_ENABLED': True,
'COMPILERS': ('pipeline_browserify.compiler.BrowserifyCompiler', ),
'CSS_COMPRESSOR': 'pipeline.compressors.NoopCompressor',
'JS_COMP
浏览 2提问于2016-01-16得票数 1
回答已采纳
我正在使用concurrent.futures.ProcessPoolExecutor并行运行python代码。基本上我所做的就是 with concurrent.futures.ProcessPollExecutor(max_workers=10) as executor:
futures = {executor.submit(my_function, i)
for i in range(n)}
for fut in concurrent.futures.as_completed(futures):
print(fut
浏览 61提问于2021-09-19得票数 1
1回答
我是Python的新手。我已经用asyncio写了一个简单的报废程序。下面是我的代码片段
loop = asyncio.get_event_loop()
task = loop.create_task(conSpi.parse(arguments.url))
value = loop.run_until_complete(asyncio.wait([task]))
loop.close()
我想打印在value.Rather中返回的结果打印变量的值，它打印如下所示
{<Task finished coro=<ConcurrentSpider.parse() done,
浏览 0提问于2017-05-18得票数 15
回答已采纳
我正在学习python并发性，并且我被介绍了未来的概念。我读到as_completed()接受了一个可迭代的未来，并在他们完成的时候产生它们。
我想知道它是如何在内部工作的。它是否立即产生完成的任务(未来)？一种天真的方法是迭代所有的未来，并使用done()检查每个未来，但这是低效的。
那么这个函数背后的魔力是什么呢？
谢谢!
浏览 2提问于2018-07-09得票数 21
回答已采纳
环境:Python3.6.2
当我尝试用以下命令安装tensorflow-gpu时：
pip3 install --upgrade tensorflow-gpu
它在尝试安装相关packeg:futures时引发错误消息。
未知需要Python '>=2.6，<3‘，但是运行的Python是3.6.2。
但是futures是python2的唯一包。
我该怎么处理呢？
浏览 0提问于2018-01-28得票数 1
我正在使用API端点来获取市场的最后价格信息，但是我需要期货市场的数据，因为有时现货和期货的最后价格之间会有很大的差距。
我怎样才能得到这个数据点？
使用binance-python和python 3。
浏览 10提问于2021-08-29得票数 0
1回答
我的未来是我广播的python集(LocalCluster)：
In [0]: [set_future] = client.scatter([_set], broadcast=True)
In [1]: set_future
Out[1]: Future: set status: finished, type: builtins.set, key: set-529f704c52fef330450e5d68302fbeac
现在，我只是想让这些数据在我的map_partitons操作中可用：
In [2]: def mapper(pdf, _set):
assert ty
浏览 6提问于2020-05-05得票数 0
我通常使用concurrent.futures.ThreadPoolExecutor在python中并发执行任务。
在执行所需的时间方面，有一个非常长且不确定的函数(它获得代理、发送HTTP请求等等)。
我想叫它几次(比方说2次)，下面是对我来说变得复杂的时候：
当任务的one完成时，我想检查它的返回值，如果它是True，继续进行代码路径，我不再关心第二个任务，也不再需要等待它了。
但是如果返回值为False，我希望等待第二个任务完成，然后继续代码路径。
我试着看看这里的几个地方，比如这个，但仍然不知道如何精确地完成它。
浏览 4提问于2018-02-05得票数 2
回答已采纳
1回答
我正在寻找一个在python中的调度程序，它可以同时启动一系列线程(恰好8个)，当其中一个线程完成时，它将添加一个新的到作业池，并启动它。此过程将继续，直到所有线程(~100)完成。
我已经看过APScheduler包了。也许通过使用add_job，我也许能够做到这一点，尽管不清楚，因为我找不到任何示例。
add_job(trigger, func, args, kwargs, jobstore='default', **options)
有人知道如何在此函数中设置触发器吗
浏览 0提问于2012-10-30得票数 2
我试图同时发送HTTP请求。为了做到这一点，我使用
下面是简单的代码：
import requests
from concurrent import futures
data = range(10)
def send_request(item):
requests.get("https://httpbin.org/ip")
print("Request {} complete.".format(item))
executor = futures.ThreadPoolExecutor(max_workers=25)
futures_ =
浏览 1提问于2018-03-24得票数 2
回答已采纳
我使用pycharm编写代码，但是当我尝试安装PyDictionary模块时，它在控制台上出现了以下错误：
系统正在使用Python3.10.2版本的windows10运行最新的pip和setuptool。设置所有必需的路径变量，并导入和安装其他模块，不存在任何问题。这种情况只发生在python 3.10.2中。
Collecting PyDictionary
Using cached PyDictionary-2.0.1-py3-none-any.whl (6.1 kB)
Collecting goslate
Using cached goslate-1.5.2.tar.g
浏览 5提问于2022-03-03得票数 1
1回答
我试图使用API获取二进制期货订单历史数据。因此，我从二进制查询数据，得到了回答：“您的历史期货订单数据申请已获批准，请按照我们的Github指导使用您的白色帐户API密钥访问”，我已经设置了API如下。
我对Enable符号白名单做了如下修改：
下一步，我遵循了Github指南：
它具有以下示例代码：
"""
This example python script shows how to download the Historical Future Order Book level 2 Data via API.
The data download
浏览 12提问于2022-04-30得票数 0
我正在使用python请求库从网站(https://www.nseindia.com/)获取JSON数据。如果提供了正确的cookie，网站才会提供数据。因此，我使用selenium webdriver获取cookie，然后获取850只不同股票的数据。 现在，我的代码是这样的:如果cookie是错误的，那么selenium应该再次打开并获得新的cookie值。但问题是，当我使用concurrent.futures时，任务非常快(由于异步)，它会为每个符号打开新的驱动程序，直到找不到新的cookies。我的代码如下： --最初获取cookies cookie_dict = get_cookie
浏览 37提问于2021-09-29得票数 1
我之前使用的是threading.Thread模块。现在我使用的是concurrent.futures -> ThreadPoolExecutor。在此之前，我使用以下代码退出/终止/结束线程：
def terminate_thread(thread):
"""Terminates a python thread from another thread.
:param thread: a threading.Thread instance
"""
if not thread.isAlive():
浏览 0提问于2018-10-04得票数 11
我正在试验Python3.2中引入的新的闪亮的模块，并且我注意到，几乎用相同的代码，使用来自concurrent.futures的池比使用要慢得多。
这是使用多处理的版本：
def hard_work(n):
# Real hard work here
pass
if __name__ == '__main__':
from multiprocessing import Pool, cpu_count
try:
workers = cpu_count()
except NotImplementedError:
浏览 4提问于2013-09-07得票数 51
回答已采纳
我有一个有很多子文件夹(比如100)的项目文件夹.python脚本导航到这些子文件夹中的每一个，调用一个可执行文件，将结果写入out文件，然后转移到下一个子文件夹。
这是我的python脚本
from dask_jobqueue import PBSCluster
cluster = PBSCluster()
cluster.scale(jobs=3)
from dask.distributed import Client
client = Client(cluster)
...
r_path='/path/to/project/folder'
def fun
浏览 4提问于2020-05-29得票数 0
回答已采纳
有几次，我列出了需要通过Python执行的任务列表。通常这些任务需要几秒钟的时间，但是有成千上万的任务，而执行则大大提高了执行时间。是否有一种方法可以动态地指定python脚本应该使用的线程数来解决一堆任务？
在Python代码正文中执行线程时，我已经成功地运行了线程，但是当线程在函数中运行时，我从未能够正确地运行它们(我认为这是因为作用域的缘故)。下面是我动态定义线程列表的方法，这些线程应该用于执行多个任务。
问题是，此方法在继续执行for循环之前等待单个线程完成。
import threading
import sys
import time
def null_thread():
浏览 19提问于2022-05-25得票数 0
我如何在ccxt下binance期货的市场订单？使用ccxt进行的binance期货交易已经实现。
https://github.com/ccxt/ccxt/pull/5907
在这篇文章中，他们建议使用这行代码：
let binance_futures = new ccxt.binance({ options: { defaultMarket: 'futures' } })
上面这行代码是用JavaScript编写的。python中的等效代码行是什么样子的？如下所示，我得到一个错误：
binance_futures = ccxt.binance({ 'option&#
浏览 31提问于2019-12-14得票数 8
是否有可能使用python转换加密货币？我在看create_order函数，但它似乎只允许现货交易。
浏览 6提问于2021-09-19得票数 0
我已经启动了一个在Scala上编写异步PostgreSQL驱动程序的项目，要成为异步的，我需要接受回调并使用将来，但是接受回调和未来会使代码变得很麻烦，因为您总是必须发送回调，即使它是无用的。
下面是一个测试：
"insert a row in the database" in {
withHandler {
(handler, future) =>
future.get(5, TimeUnit.SECONDS)
handler.sendQuery( this.create ){ query => }.get( 5, Time
浏览 0提问于2012-03-10得票数 3
回答已采纳
我在多线程环境中使用断言来帮助我捕获早期的bug。但事实证明，当断言失败时，python3.7只是静默地终止，而不打印我想要看到的错误消息。感谢您提前提供帮助。 以下是示例代码： from concurrent.futures import ThreadPoolExecutor
import threading
import random
from time import sleep
def task():
assert False, "no assertion output, why?"
print("Executing our Task")
浏览 39提问于2019-05-12得票数 2
回答已采纳
1回答
我有两个用Kotlin Vert.x编写的Hello World句柄方法。我想清楚地了解他们是如何工作的，如果可能的话。一个是AsyncVertilce，另一个是CompositeVerticle。
这是Hello World协程异步垂直句柄方法。
var result = async {
callFunctionAwait(
getDependentAddress(HELLO_WORLD), message.headers(), message.body(), messageMarker
)
}
var res
浏览 8提问于2021-10-24得票数 0
我正在使用TreadPoolExecutor来运行异步任务。我想知道是否有一种方法可以列出需要完成的期货，而不必手动跟踪它们。Python文档在这个主题上有些稀疏。
浏览 15提问于2020-08-06得票数 0
在Python中，我通常会使用标准库中的队列(这是线程安全的)，并编写一个函数来使用队列中的url，并将下载的内容保存到磁盘上。我会在threading.Threads中产生一些这样的函数。如果下载失败，我会再次将相同的url放入队列中。
用Scala编写一个类似的并发下载器的惯用方法是什么？我应该使用哪些抽象？
浏览 2提问于2016-08-11得票数 1
我在使用时遇到了问题。
我在Ubuntu上使用Python3.7
基本上，在进行下面的调用时，我会得到一个错误：{“代码”：-2015，“msg”：“无效API-key，
问题是，这个ID在Binance TESTNET上运行良好，用于限制和市场订单。这是我唯一有问题的订单类型。我还在这里记录了这条消息：
我想在期货交易所做这件事。
retval = self.exchange.private_post_order_oco({
'symbol': symbol,
'side': side,
'quantity': sel
浏览 5提问于2020-12-06得票数 2
异步模块的描述如下：
该模块提供了一个基础结构，用于使用协同器编写单线程并发代码、在套接字和其他资源上复用I/O访问、运行网络客户端和服务器以及其他相关原语。
我一直在阅读关于新的和不寻常的异步python模块/包/任何东西。我知道这里有python，所以异步非常适合GIL，因为(目的是)在单个线程上使用一个事件循环来管理事情。那么什么是并发呢？看来I/O似乎是并行的。我相信I/O操作是由操作系统处理的。那么，在异步的内部，它是否编写了一个并发的C扩展，利用操作系统提供的功能？
浏览 3提问于2016-12-17得票数 1
当我试图在vim中使用YouCompleteMe插件时，我会得到以下错误：
YouCompleteMe unavailable: This package should not be accessible on Python 3. Either you are trying to run from the python-future src folder or your installation of python-future is corrupted
但是，只有在我的虚拟环境中打开vim时，我才会得到这个错误。当虚拟主机不活动时，它可以正常工作。我的猜测是，YouCompleteMe是用
浏览 21提问于2016-08-18得票数 2
回答已采纳
来自asyncio
asyncio.as_completed(aws, *, loop=None, timeout=None)
同时运行aws集合中的可访问对象。返回未来对象的迭代器。每个返回的未来对象表示剩余的可等待对象集合的最早结果。
我假设每个Future对象都有：.cancelled()、.exception()和.result()中描述的方法。但是，似乎生成的元素只是协同，而不是Future对象。我遗漏了什么？
这似乎不符合.as_completed()的描述。如果我需要await，协同线是如何“完成”的？
>>> import asyncio
>&
浏览 0提问于2018-11-01得票数 9
回答已采纳
1回答
REST调用使用spray.io。它使用各种函数验证调用中的请求，其中包括查询数据存储的中间函数。如果一切正常，则写到所述数据存储区。在这种情况下，最多有4个IO操作: HTTP请求、数据读取、数据写入和HTTP响应。如果我决定使用IO monad，那么如果我有一些可能或不需要的IO (例如，如果一些验证失败了就不需要进行读写操作)，那么我将如何构造执行IO呢？想必，首先，我可以先忽略喷雾剂的东西，并认为评估是从喷雾完成后开始的。但是如何将IO函数与非IO函数组合起来呢？我一定要把那些非伊奥的东西搬到单桅帆船上吗？
浏览 3提问于2014-05-08得票数 0
回答已采纳
这将为将来添加一个成功/错误处理程序，例如：
async function send(item) {
// ...
}
for (const item of items) {
const sendPromise = send(item);
sendPromise
.then(x => console.log(x))
.catch(x => console.error(x))
}
而不是像这样等待：
for (const item of items) {
const sendPromise = send(item);
浏览 0提问于2019-08-08得票数 0
回答已采纳
我在循环中接收消息，我希望循环是可取消的，所以我使用asyncio.Event对象作为循环何时退出的标志，如下所示：
class MyThing:
def __init__(self):
self.quit = asyncio.Event
async def loop(self):
while True:
t1 = self.quit.Wait()
t2 = self.recv_message()
done, pending = asyncio.wait([t1, t2],
浏览 2提问于2020-11-13得票数 0
回答已采纳
我是异步Python的新手。我研究异步迭代器的行为。我所做的一切都是pep492写的。RuntimeError:任务获得了糟糕的收益: 1。请理解我做错了什么。在这个网站上，我读到了这个错误，但什么也不明白。
class Awaitable:
def __await__(self):
i = 1
while i < 3:
yield i
print("yield {}".format(i))
i +=1
return i
class Async
浏览 1提问于2018-03-18得票数 2
2回答
我正在运行一个算法来预测价格，并使用python中的ccxt为我输入交易。我希望执行一个尾随止损单，我进入了这样一个长期的职位：
exchange = ccxt.binance({
'enableRateLimit': True,
'apiKey': '*****',
'secret': '*****'
})
exchange.load_markets()
exchange.create_order('MKR/USDT, 'TRAILING_STOP_MARKET'
浏览 7提问于2021-04-24得票数 1
回答已采纳
1回答
我有运行24/7的脚本，有时当concurrent.futures中的线程对请求没有响应时，这些脚本就会卡住。打印出哪个线程挂起以及原因。
指纹看起来是这样的：
Thread 139646566659840 "ThreadPoolExecutor-666849_1" hangs -
浏览 12提问于2022-10-26得票数 0
从javadocs，
AllOf()
如果任何给定的 CompletableFutures都是异常完成的，则返回的CompletableFuture也会这样做，其中一个CompletionException将此异常作为其原因。
AnyOf()
如果异常完成，返回的CompletableFuture也会这样做，CompletionException将此异常作为其原因。
这是否意味着allOf()和anyOf()在任何CompletableFuture抛出异常时都以相同的方式运行？
问题在于这句话
返回的CompletableFuture也这样做
出现在这两个方法中，而没有
浏览 0提问于2019-01-28得票数 0
回答已采纳
你好，我需要在二进制环境下修改dca bot的python脚本，我想修改在二进制上交易的原始脚本，我修改了exchange部分，但是当我尝试在visual studio中运行该脚本时，遇到了这个问题：
回溯(最近一次调用)：文件"c:\Users\TEHH\Desktop\Binance-Futures-DCA-4Bot-main\Binance-Futures-DCA-Bot-main\strategy copy 2.py"，第41行，位置=balance‘’info‘
你能帮我修改一下代码以便能在现场使用吗，
github ccxt：
代码：
import config
浏览 5提问于2022-02-09得票数 0
我正在尝试python的concurrent.futures文档中的这个example code for python's ThreadPoolExecutor。具体来说 import concurrent.futures
import urllib.request
URLS = ['http://www.foxnews.com/',
'http://www.cnn.com/',
'http://europe.wsj.com/',
'http://www.bbc.co.uk/&#
浏览 32提问于2019-04-01得票数 2
回答已采纳
1回答
我正在尝试理解在异步Rust Future中轮询是如何工作的。使用下面的代码，我尝试运行两个期货Fut0和Fut1，这样它们就像下面的Fut0 -> Fut1 -> Fut0 -> Fut0一样交错。
extern crate futures; // 0.3.1
use std::future::Future;
use std::pin::Pin;
use std::task::{Context, Poll, Waker};
use std::cell::RefCell;
use std::rc::Rc;
use std::collections::HashMap;
浏览 3提问于2019-11-22得票数 1
2回答
void process(String question){
Callable<ResponseList> callable1 = () -> this.stsCompute question);
Future<ResponseList>task1 = executorService.submit(callable1);
Callable<ResponseList> callable2 = () -> this.dssmCo
浏览 0提问于2018-11-03得票数 1
回答已采纳
我正试图在AWS lambda上运行python Cassandra驱动程序。我遵循了关于如何使用cassandra驱动程序依赖构建部署包的。我仍然无法使它工作，因为这个错误：
Unable to import module 'login': /var/task/cassandra/cluster.so: undefined symbol: PyFPE_jbuf
我发现了另一个与这个问题相关的，其中说驱动程序3.7.1版本解决了这个问题(并且可以确认为)，但是我仍然得到它。
在aws上运行python驱动程序的人也有相同的问题吗？
谢谢
浏览 4提问于2017-01-05得票数 0
回答已采纳
1回答
我已经尝试过Tokio任务，但是没有可以一次执行多个任务的工作示例。这个代码有什么问题？
fn main() {
block_on(speak());
}
async fn speak() {
let hold = vec![say(), greet()];
let results = join_all(hold).await;
}
async fn say() {
println!("hello");
}
async fn greet() {
println!("world");
}
这是编译器的输出
error[
浏览 2提问于2020-08-18得票数 7
场景：用户A连接到dask调度程序，使用client.map(func, list)发送一个长作业，并在周末注销。用户B希望查看用户A创建的已完成期货的结果，并可能取消挂起的期货。
我们设法得到了工人的期货结果如下：
from dask.distributed import Client
from distributed.client import Future
client = Client("tcp://scheduler_ip:8786")
for worker, futures in client.has_what().items():
for future_
浏览 2提问于2017-08-25得票数 1
2回答
函数不等待异步函数。
、、、、
我需要函数_get_datos_restaurante()等待其他函数(_get_nombre_provincia()和_get_valoracion_media() )结束，但我无法做到这一点。问题是变量valoracion_media在_get_datos_restaurate()结束时不能正确地“操作”。这些函数是异步的，我在FutureBuilder中使用的是FutureBuilder()，所以我不知道是什么错误。这是我的代码：
Future<void> _get_datos_restaurante(String id, QueryDocumentSnapshot r) a
浏览 8提问于2022-03-16得票数 0
1回答
就我所理解的Akka文档而言，Akka ActorSystem包含自己的线程池来执行参与者。我在一个也使用Java8期货的Java应用程序中使用Akka；后者由ForkJoinPool.commonPool()执行。因此，参与者和期货使用不同的池，这可能会击败隐藏在两个调度器中的某些假设(例如，Akka调度器可能假定期货在Akka池上运行)。这会造成任何性能问题吗？
浏览 3提问于2015-04-08得票数 4
回答已采纳
我正在尝试创建一个方法，它在CompletableFuture变量中计算IntStream中计算的其他CompletableFutures的和。不幸的是，我的值并没有添加到我需要的最后一个变量中，结果是0。我的代码如下：
CompletableFuture<Long> finalAmount = CompletableFuture.completedFuture(0L);
IntStream.range(rankUpEvent.getOldClubRank()+1, rankUpEvent.getNewClubRank()).forEach(
rank -> {
浏览 8提问于2021-08-09得票数 0
回答已采纳
1回答
我很难理解@Async注释和方法的用法，因为我在多线程领域非常缺乏经验。
我有一些Map<Integer, String> map，我想使用异步方法调用来更新这个map。该方法在页面上发出HTTP GET请求，int id返回String string作为结果--它被更新为map，我需要得到更新后的结果值：
@Async
public Future<Entry<Integer, String>> updateEntry(Integer key, String value) {
Entry<Integer, String> entry =
浏览 0提问于2018-08-19得票数 3
回答已采纳
我的应用程序使用的是颤振。我需要从Firebase实时数据库(例如50种不同的数据位置)查询大量信息，因此我需要异步启动它们，并在更新UI之前等待它们全部返回，以显示信息。
我怎样才能在颤栗中实现这一点呢？使用异步，等待，我只能等待一个异步函数。
浏览 3提问于2020-12-13得票数 5
回答已采纳
对于在Rust中异步调度和执行的“就绪”方法，我有一个疑问，因为它与基于运行时语言的“完成”方法(Python，Node.js)有关。我使用的是“就绪”和“完成”，这是的术语引发了这个问题。
如果我得到的是正确的，锈蚀期货(如std-futures)在“准备状态”方法下实现：
包装在任务内部，将封装的未来的私有调用堆栈存储在内存中，以允许其中断和恢复，假设其他期货在间隔内运行；
由于一些i/o参与者调用任务(通过任务已针对相关的i/o参与者注册的回调)，他们对包装任务进行了轮询；
当任务链中的所有其他任务或任务链中的i/o参与者都已注册回调时才返回值，而这些任务或I/O参与者由于他
浏览 5提问于2020-04-26得票数 2
回答已采纳
2回答
直到最近，我一直在与Google和ListenableFutures进行广泛的合作，而我一直发现缺少的是一种为将来的完成提供无序流处理程序的方法。我所设想的是一个可迭代的，它阻塞了next()，直到另一个未来的返回。
在我努力创造自己之前，一个人是否已经存在了？
如果不是，我的想法是利用ListenableFuture的回调功能将结果推送到BlockingQueue上。目标是在返回值返回后立即处理它们。Futures.successfulAsList()很棒，但是在返回之前等待所有的值，而不是让我安排其他有用的工作。
浏览 2提问于2012-09-03得票数 4
回答已采纳
1回答
背景
据称，
中的程序是关于
与带有mnist模型的tensorflow_model_server对话的客户端。
客户端下载mnist数据集的测试映像，使用
这样的测试图像可以得到预测，并计算出推理错误率。
问题
我很难理解gRPC客户端请求的并发性。
for _ in range(num_tests): # <==
request = predict_pb2.PredictRequest()
request.model_spec.name = 'mnist'
request.model_spec.signatur
浏览 4提问于2020-02-13得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
