Tag: AKKA-STREAM
Estoy intentando transmitir tweets en función de cuándo ciertas personas publican a través de la transmisión en tweepy. Cuando ejecuto el siguiente código, obtengo retuits mezclados en los datos. ¿Existe alguna manera de obtener los tweets de los usuarios en tiempo real sin retuits? with open(‘twitter_list.txt’) as user_list: usernames = . . . Read more
Necesito poder identificar algunos archivos binarios grandes que han sido copiados y renombrados entre servidores seguros. Para hacer esto, me gustaría poder hacer hash de los primeros X bytes y los últimos X bytes de todos los archivos. Necesito hacer esto solo con lo que está disponible en un sistema . . . Read more
Estoy tratando de controlar dinámicamente el tamaño y la posición de una caja en un flujo rtsp expuesto por ffmpeg. Encontré una solución potencial que se basa en zmq. Recompilé ffmpeg con soporte zmq y ejecuté el flujo con el comando: ffmpeg -re -rtsp_transport tcp -stimeout 1000000 -i "rtsp://<STREAM_ADDR>" -pix_fmt . . . Read more
Estoy intentando obtener datos de trading en vivo desde Internet a través de HTTP, pero se actualiza continuamente, así que si hago una petición GET, seguirá descargando mientras haya datos disponibles. Hasta que detenga la transmisión de descarga, entonces podré acceder a los datos. ¿Cómo acceder al flujo de datos . . . Read more
Estoy recibiendo un Multipart/FromData como servidor. Esta solicitud contiene Source[Multipart.FormData.BodyPart, Any] y cada Multipart.FormData.BodyPart contiene Source[ByteString, Any] en su interior. Soy capaz de establecer un tamaño de búfer. Pero mide en cantidad de elementos. ¿Cómo puedo calcular el tamaño de cada elemento ByteString (tamaño de lote)? Necesito calcular todo el . . . Read more