Tag: DASK-DISTRIBUTED
Estoy utilizando Dask en un entorno de clúster a través de Dask-gateway. Creé el grafo de computación en un cuaderno de Jupyter. Dentro de mi función retrasada, llama a varias funciones definidas en varios archivos .py separados. Actualmente, me estoy encontrando con un error en el trabajador que dice que . . . Read more
EDITAR: Mi pregunta fue horriblemente formulada, así que la borro y la reformulo por completo aquí. Daré un resumen: Estoy tratando de asignar cada cálculo a un trabajador designado que se adapte al tipo de cálculo. En resumen: Estoy tratando de ejecutar una simulación, por lo que la represento utilizando . . . Read more
Problema ¿Alguien sabría cómo recuperar el enlace del panel de control de dask cuando envío mi trabajo dask-yarn? Tengo una declaración de impresión para mostrar el enlace del panel de control de dask, pero no aparece en la consola. También he intentado registrar en stdout y tratar de ver si . . . Read more
Estoy intentando utilizar shared_memory en un clúster distribuido con Python multiprocessing. Cada vez que se crea un trabajador en un nuevo nodo, necesito que verifique si ya existe un bloque de memoria compartida con un nombre específico y, si no existe, lo cree a partir de un subconjunto de una . . . Read more
Digamos que tenemos que realizar una prueba de carga de rendimiento con 100 usuarios utilizando el usuario jmeter de pruebas distribuidas. ¿Cómo distribuyo esta carga entre 3 esclavos y 1 máquina maestra?