我曾尝试在~/.config/dask/distributed.yaml和~/.config/dask/yarn.yaml中使用以下内容， sample_formatter:
format: '%(asctime)s - %(name)s - %(levelname)s -
浏览 3提问于2019-08-23得票数 0
回答已采纳
1回答
我正在尝试使用dask配置文件在dask中设置记录器，在文档中显示here。我的~/.config/dask/dask.yaml配置文件是： logging: formatters: format:loggers:
distr
浏览 16提问于2020-11-23得票数 0
我的原始脚本使用pool.map并行运行。我在代码中设置了记录器，以便输出到一个文件，而运行在不同进程中的代码将日志输出到同一个文件。现在，我尝试使用dask进行多进程处理，发现记录器设置在其他进程中无效。我试图在client =Client(集群)之后移动setup_logger，它仍然不能工作。
我还尝试了类似logger = getLogger()之类的东西，然后直接
浏览 9提问于2022-09-23得票数 0
$ dask-worker --version是Dask和Dask共享相同的配置文件还是使用不同的配置文件？我在我的系统和Dask文档中找到了三个不同的配置文件：
~/.config/dask</e
浏览 0提问于2019-09-06得票数 0
回答已采纳
my_task()：dask_worker_log_msg(“def”) ...future = client.submit(my_task) print("dask_client_log_msg我希望将"dask_client_log_msg“和其他任务日志捕获到一个文件中，将"dask_worker_log_msg”和其他客户端日志捕获到一个单独的文件中。很明显，客户端将在与工作进程完全不同的进程中
浏览 0提问于2018-02-01得票数 3
)) return_a() address: "scheduler:8786"$ dagster pipeline execute
浏览 11提问于2021-04-07得票数 2
回答已采纳
是否可以在YAML配置文件中为Dask仪表板指定默认端口？以便可以为非随机端口设置SSH隧道。我知道我可以这样做：但是这个默认值可以在配置文件中指定吗？我试过了
dask.config.set({'distributed.dashboard_address': 'lo
浏览 1提问于2020-03-05得票数 0
在我的Dask配置文件(即~.config/dask/yarn.yaml )中，我将worker环境变量设置为：
name: dask # ApplicationARROW_LIBHDFS_DIR": "/usr/hdp/lib"} # A map of environment variabl
浏览 0提问于2019-08-16得票数 0
回答已采纳
查看页面:纱线配置文件yarn.yaml文件需要放置在位置~/.config/dask/yarn.yaml或/etc/dask/yarn.yaml中。它是否也被放置在环境变量DASK_ROOT_CONFIG指定的位置(如 )？
浏览 2提问于2019-06-08得票数 0
回答已采纳
2回答
在编写“记录器：”指令时，我希望使用一个记录器，并能够使用getLogger(__name__)从我的应用程序中的多个模块获取它。如果我使用一个普通的python配置文件进行日志记录，我知道如何做到这一点，但我无法找到对yaml文件进行同样操作的方法。但我希望能够在配置中设置--而不是某个不同的记录器(这里我称之为“app”)，而是一个通用的，就
浏览 1提问于2017-11-03得票数 0
回答已采纳
我的文件结构如下：--> __init.py__----> some_file.py
在__init.py__中，我从yaml文件中的dict配置创建根记录器我记录了它的effectiveLevel，它和预期的一样(在yaml文件中设置为INFO )。但是，我在some_file.py中记
浏览 0提问于2014-08-01得票数 1
我在k8s集群()上部署了一个单用户dask舵机图表。-2021.11.2 2021.11.2 NAME TYPE我的k8s不允许使用LoadBalancer服务，所以我尝试启用入口。为了公开外部ip，我试图按照以下模板启用入口： ingress:
浏览 28提问于2022-01-06得票数 0
回答已采纳
我使用以下代码创建了一个集群cluster = KubeCluster.from_yaml('worker.yaml')cluster.adapt(minimum=1, maximum=10)kind: Pod labels:
foo:args: [dask-worke
浏览 1提问于2020-02-01得票数 1
import dask.bag
在我的例子中，execute()函数执行大量IO操作，大约需要5-10分钟才能运行。我想配置KubeCluster和dask调度程序，使它们能够最大限度地完成这些长期运行的任务。
浏览 2提问于2020-01-29得票数 0
1回答
在Dask中更改临时目录时遇到问题。当我出于某种原因更改了dask.yaml中的临时目录时，Dask仍在用/tmp写出(它已满)。我现在想尝试并调试它，但是当我使用client.get_worker_logs()时，我只能得到信息输出。我从我的集群开始 from dask.distributed import LocalCluster, Client
cluster = LocalCluster(n_workers=1,
浏览 25提问于2019-09-19得票数 1
回答已采纳
1回答
我发布的软件使用分布式，跨进程并行化。我从调度器文件(通过dask创建)和LocalClusters为用户创建客户端对象。如何在安装过程中，不让用户自己完成工作，就可以为用户关闭窃取工作的功能？
浏览 0提问于2018-03-18得票数 1
回答已采纳
我正在配置dask以在HPC集群上运行。我设置了一个客户机，如下所示：from dask_jobqueue import SLURMCluster
JOB_ID=${SLURM_JOB_ID%;*}
/path/to/python3 -m distributed.cli.dask</e
浏览 0提问于2019-05-15得票数 1
回答已采纳
我正在尝试使用JupyterLab中的Dask扩展启动一个新的SLURM集群。当我点击'+New‘按钮时，我遇到了以下弹出窗口：这是尽管在~/.config/dask中有一个包含'dask_jobqueue‘模块的labextension.yaml此屏幕截图显示了问题，以及我在后台的配置文件：我是不是误解了什么？
浏览 10提问于2021-03-13得票数 1
回答已采纳
我能够以这种方式与symfony2中的理论联系起来：doctrine: default_connection: defaultdatetime_functions:现在我的问题是，如何在上面的配置中实现这一点由于这是一个$config方法，我想应该可以在</e
浏览 3提问于2015-01-08得票数 1
我正在尝试将一个自适应的dask kubernetes集群部署到我的aws K8s实例(我想使用中的kubeControl接口)。我不清楚我在哪里以及如何执行这段代码，以便它在我现有的集群上是活动的。除此之外，我还希望有一个入口规则，以便我拥有的另一个ec2实例可以连接到集群并在aws VPC中执行代码，以维护安全性和网络性能。话虽如此，我可以使用公开的AWS dns服务器从我的另一个ec2实例连接到这个集群，并执行自定义代码，但这不是kubernetes原生dask集
浏览 1提问于2019-09-20得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
