[Python-es] Leer fichero al mismo tiempo que se está escribiendo por otro proceso.

Jue Jul 4 14:29:52 EDT 2019

El archivo está vacío, así que chunk es una cadena vacía. Esa función asume
que el archivo no está creciendo, así que cuando no lee más, el archivo
está terminado.

On Thu, 4 Jul 2019, 7:56 pm Raúl Alexis Betancor Santana, <
rabs en dimension-virtual.com> wrote:

> Haciendo más pruebas, he llegado a la conclusión, de que lo que está mal
> es la función de read_in_chunks ... ya que nunca lee nada y siempre acaba
> dentro del if not chunk: break ... y no entiendo porque narices.
>
> En todos los ejemplos que encuentro por la red para leer un fichero
> binario por porciones, siempre usan mas o menos el mismo estilo de código
> para la función, pero esta parece que nunca lee nada.
>
> ¿Que estoy haciendo rematadamente mal, que no soy capaz de leer un fichero
> binario a trozos? ... :-(
>
> ------------------------------
>
> *De: *"Raúl Alexis Betancor Santana" <rabs en dimension-virtual.com>
> *Para: *"python-es" <python-es en python.org>
> *Enviados: *Jueves, 4 de Julio 2019 13:55:56
> *Asunto: *Re: [Python-es] Leer fichero al mismo tiempo que se está
> escribiendo por otro proceso.
>
> No puedo, los ficheros los genera Asterisk y no voy a estar tocando el
> código para eso.
>
> He probado añadiendo un delay de 250ms al inicio de la lectura, para darle
> tiempo a que haga un flush a disco, pero tampoco me vá.
>
> En realidad lo que me mosquea, es que un ejemplo que tengo en Node.js y
> que hace exactamente lo mismo, funciona perfectamente, pero el código de
> python se me queda en el for response in responses: ... osea, no llega
> nunca a recibir respuesta de GCS o el generador del read_in_chunks no está
> resolviendo o algo raro.
>
> Ahora lo estoy intentando con ARI, porque llevo días intentandolo con un
> script en python que ejecutaba desde el EAGI y tampoco había forma, o
> escuchaba el stream de audio y lo interpretaba o reproducía una locución
> del IVR, pero no ambas cosas al mismo tiempo y hacerlo vía threads, se me
> complicaba la cosa, hacerlo vía multiprocess y pipes, tenía el problema de
> que tenía que estar leyendo desde el proceso hijo el FD 3 del proceso
> padre, un coñazo.
>
> Si ha alguien se le ocurre como resolver esto ... estoy abierto a ideas.
>
> ------------------------------
>
> *De: *"Daπid" <davidmenhur en gmail.com>
> *Para: *"python-es" <python-es en python.org>
> *Enviados: *Jueves, 4 de Julio 2019 11:57:11
> *Asunto: *Re: [Python-es] Leer fichero al mismo tiempo que se está
> escribiendo por otro proceso.
>
> Creo que has encontrado la solución, pero la has puesto en el lugar
> equivocado.
>
> #audio_file = io.open(stream_file+'.sln16','rb',buffering=0)
>
> El proceso que está escribiendo al archivo está probablemente usando un
> buffer, lo que quiere decir que sólo escribe al disco duro de vez en
> cuando, cuando haya acumulado una cierta cantidad de datos. Si tienes
> acceso al programa que escribe el archivo, tienes que o bien desactivar el
> buffer (¡cuidado con el rendimiento!), usar uno más pequeño, o vaciarlo
> explícitamente con un flush() más a menudo.
>
>
>
> On Thu, 4 Jul 2019 at 12:28, Raúl Alexis Betancor Santana <
> rabs en dimension-virtual.com> wrote:
>
>> Buenas, estoy intentando hechar a andar el Google Cloud Speech, he
>> intento leer en stream de un fichero que está siendo escrito por otro
>> proceso, que contiene la grabación del audio, para enviarla al GCS, pero
>> sin éxito.
>>
>> ¿Alguien me puede comentar que estoy haciendo mal?, con el ejemplo que da
>> GCS para hacer lo mismo con un fichero directamente, que lo que hace es
>> leerlo completo en memoria y enviarlo, no me da problemas y transcribe bien
>> el texto.
>>
>> Basandome en el código de ejemplo de GCS para streaming
>>
>> def read_in_chunks(file_object,chunk_size):
>>    """Lazy function (generator) to read a file piece by piece.
>>    while True:
>>      chunk = file_object.read(chunk_size)
>>      if not chunk:
>>        return
>>      data = [chunk]
>>      yield b''.join(data)
>>
>> def transcribe_streaming(stream_file,language,timeout):
>> """Streams transcription of the given audio file."""
>> from google.cloud import speech
>> from google.cloud.speech import enums
>> from google.cloud.speech import types
>> import io
>> client = speech.SpeechClient()
>>
>> #audio_file = io.open(stream_file+'.sln16','rb',buffering=0)
>> audio_file = io.open(stream_file+'.sln16','rb')
>> # In practice, stream should be a generator yielding chunks of audio
>> data.
>> requests = (types.StreamingRecognizeRequest(audio_content=chunk)
>> for chunk in read_in_chunks(audio_file,3200))
>>
>> config = types.RecognitionConfig(
>> encoding=enums.RecognitionConfig.AudioEncoding.LINEAR16,
>> sample_rate_hertz=16000,
>> language_code=language)
>> #streaming_config =
>> types.StreamingRecognitionConfig(config=config,single_utterance=True)
>> streaming_config = types.StreamingRecognitionConfig(config=config)
>>
>> # streaming_recognize returns a generator.
>> responses = client.streaming_recognize(streaming_config, requests)
>> for response in responses:
>>    # Once the transcription has settled, the first result will contain
>> the
>>    # is_final result. The other results will be for subsequent portions
>> of
>>    # the audio.
>>    for result in response.results:
>>       if result.is_final:
>>          print('Finished: {}'.format(result.is_final))
>>          print('Stability: {}'.format(result.stability))
>>          alternatives = result.alternatives
>>          ### The alternatives are ordered from most likely to least.
>>          for alternative in alternatives:
>>             print('Confidence: {}'.format(alternative.confidence))
>>             print(u'Transcript: {}'.format(alternative.transcript))
>> (null)
>> _______________________________________________
>> Python-es mailing list
>> Python-es en python.org
>> https://mail.python.org/mailman/listinfo/python-es
>>
>
> _______________________________________________
> Python-es mailing list
> Python-es en python.org
> https://mail.python.org/mailman/listinfo/python-es
>
>
> _______________________________________________
> Python-es mailing list
> Python-es en python.org
> https://mail.python.org/mailman/listinfo/python-es
>
> _______________________________________________
> Python-es mailing list
> Python-es en python.org
> https://mail.python.org/mailman/listinfo/python-es
>
------------ próxima parte ------------
Se ha borrado un adjunto en formato HTML...
URL: <http://mail.python.org/pipermail/python-es/attachments/20190704/fab677c2/attachment.html>