Tag: DASK-DISTRIBUTED
Estoy tratando de ejecutar una función en diferentes combinaciones de todos los elementos en diferentes matrices con Dask, y estoy luchando para aplicarla. El código en serie es el siguiente: for i in range(5): for j in range(5): for k in range(5): función(listaA[i], listaB[j], listaC[k]) print(f'{i}.{j}.{k}’) k=k+1 j=j+1 i=i+1 El . . . Read more
Información general Estoy construyendo una aplicación de stock como un proyecto secundario y esta es la arquitectura actual que estoy usando: Frontend de React con la biblioteca de sockets @microsoft/signalr Backend de ASP.NET Core con SignalR Hub para manejar los sockets del cliente API REST de Polygon.io como fuente de . . . Read more
Por favor, guíame en la definición de la función de llamada remota: log: [root@srvr0 ~]# julia -p 4 _ _ _ _(_)_ | Documentación: https://docs.julialang.org (_) | (_) (_) | _ _ _| |_ __ _ | Escribe “?” para obtener ayuda, “]?” para obtener ayuda de Pkg. | | . . . Read more
Me gustaría ejecutar la función f() en mis 4 procesadores (Intel i7) y obtener la suma de los números aleatorios, de la siguiente manera: using Distributed; @everywhere function f() return sum(rand(10000)) end @sync for w in workers() @async begin res = @spawnat w f() values[w-1] = fetch(res) end end Sin . . . Read more
Estoy utilizando Dask Bag para ejecutar algunos cálculos de map-reduce simples en un clúster especial: import dask.bag as bag summed_image = bag.from_sequence(my_ids).map(gen_image_from_ids).reduction(sum, sum).compute() Este código genera una secuencia de cálculos encadenados, comienza mapeando desde from_sequence y gen_image_from_ids, y luego reduce todos los resultados en uno solo con sum. Gracias a . . . Read more