qiB+ddlZddlmZddlZddlZddlmZmZm Z m Z m Z ddl m Z mZerddlmZe j"eZded ed ej,fd Zeed Gdde Zy)N)Any)add_end_docstringsis_torch_availableis_torchaudio_availableis_torchcodec_availablelogging)Pipelinebuild_pipeline_init_args),MODEL_FOR_AUDIO_CLASSIFICATION_MAPPING_NAMESbpayload sampling_ratereturnc z|}d}d}dddd|d|d|d d d d g } tj|tjtj }|j |}|d}t j|t j} | jddk(r t d| S#t$r t dwxYw)z? Helper function to read an audio file through ffmpeg. 1f32leffmpegz-izpipe:0z-acz-arz-fz -hide_bannerz -loglevelquietzpipe:1)stdinstdoutzFffmpeg was not found but is required to load audio files from filenamerzMalformed soundfile) subprocessPopenPIPEFileNotFoundError ValueError communicatenp frombufferfloat32shape) rraracformat_for_conversionffmpeg_commandffmpeg_process output_stream out_bytesaudios ]/opt/pipecat/venv/lib/python3.12/site-packages/transformers/pipelines/audio_classification.py ffmpeg_readr+s ?B B#      N c#)). XbXgXgh#..x8Ma I MM)RZZ 0E {{1~.// L cabbcs 4B%%B:T)has_feature_extractorc eZdZdZdZdZdZdZfdZde je ze ze zdedee e efffd Zd d Zd Zd Zdd ZxZS)AudioClassificationPipelinea Audio classification pipeline using any `AutoModelForAudioClassification`. This pipeline predicts the class of a raw waveform or an audio file. In case of an audio file, ffmpeg should be installed to support multiple audio formats. Example: ```python >>> from transformers import pipeline >>> classifier = pipeline(model="superb/wav2vec2-base-superb-ks") >>> classifier("https://huggingface.co/datasets/Narsil/asr_dummy/resolve/main/1.flac") [{'score': 0.997, 'label': '_unknown_'}, {'score': 0.002, 'label': 'left'}, {'score': 0.0, 'label': 'yes'}, {'score': 0.0, 'label': 'down'}, {'score': 0.0, 'label': 'stop'}] ``` Learn more about the basics of using a pipeline in the [pipeline tutorial](../pipeline_tutorial) This pipeline can currently be loaded from [`pipeline`] using the following task identifier: `"audio-classification"`. See the list of available models on [huggingface.co/models](https://huggingface.co/models?filter=audio-classification). FTc~d|vr |dd|d<n d|vrd|d<t||i||jty)Ntop_k)super__init__check_model_typer )selfargskwargs __class__s r*r3z$AudioClassificationPipeline.__init__bsO f !8"F7O F "F7O $)&) JKinputsr7rc $t||fi|S)a Classify the sequence(s) given as inputs. See the [`AutomaticSpeechRecognitionPipeline`] documentation for more information. Args: inputs (`np.ndarray` or `bytes` or `str` or `dict`): The inputs is either : - `str` that is the filename of the audio file, the file will be read at the correct sampling rate to get the waveform using *ffmpeg*. This requires *ffmpeg* to be installed on the system. - `bytes` it is supposed to be the content of an audio file and is interpreted by *ffmpeg* in the same way. - (`np.ndarray` of shape (n, ) of type `np.float32` or `np.float64`) Raw audio at the correct sampling rate (no further check will be done) - `dict` form can be used to pass raw audio sampled at arbitrary `sampling_rate` and let this pipeline do the resampling. The dict must be either be in the format `{"sampling_rate": int, "raw": np.array}`, or `{"sampling_rate": int, "array": np.array}`, where the key `"raw"` or `"array"` is used to denote the raw audio waveform. top_k (`int`, *optional*, defaults to None): The number of top labels that will be returned by the pipeline. If the provided number is `None` or higher than the number of labels available in the model configuration, it will default to the number of labels. function_to_apply(`str`, *optional*, defaults to "softmax"): The function to apply to the model output. By default, the pipeline will apply the softmax function to the output of the model. Valid options: ["softmax", "sigmoid", "none"]. Note that passing Python's built-in `None` will default to "softmax", so you need to pass the string "none" to disable any post-processing. Return: A list of `dict` with the following keys: - **label** (`str`) -- The label predicted. - **score** (`float`) -- The corresponding probability. )r2__call__)r5r:r7r8s r*r<z$AudioClassificationPipeline.__call__lsDw1&11r9c ,i}|$|jjj|d<nH||jjjkDr |jjj}||d<||dvrtd|d||d<nd|d<ii|fS)Nr0)softmaxsigmoidnonez'Invalid value for `function_to_apply`: z2. Valid options are ['softmax', 'sigmoid', 'none']function_to_applyr>)modelconfig num_labelsr)r5r0rAr7postprocess_paramss r*_sanitize_parametersz0AudioClassificationPipeline._sanitize_parameterss =*.***;*;*F*F w 'tzz((333 ))44*/ w '  ( (FF =>O=PQGG7H 2 36? 2 32)))r9ct|tri|jds|jdr"tj|dj }n%t |d5}|j}dddt|tr t||jj}tr8ddl }t||jr|jj!}t#rSddl }ddl}t||j&j(r+|j+}|j,}||j.d}t|t0r |j3}d|vrd |vsd |vs t5d |j7d d}|$|j7d d|j7d d}|j7d}|}||jjk7rddl }t9rdd lm} n t?d| jAt|tBjDr|jG|n|||jjj!}t|tBjDs tIdtK|jLdk7r t5d|j||jjd} |jN| jQ|jN} | S#1swYxYw)Nzhttp://zhttps://T)follow_redirectsrbr)arrayrrrawrJzWhen passing a dictionary to AudioClassificationPipeline, the dict needs to contain a "raw" key containing the numpy array or torch tensor representing the audio and a "sampling_rate" key, containing the sampling_rate associated with that arraypath) functionalztorchaudio is required to resample audio samples in AudioClassificationPipeline. The torchaudio package can be installed through: `pip install torchaudio`.z2We expect a numpy ndarray or torch tensor as inputr zFWe expect a single channel audio input for AudioClassificationPipelinept)rreturn_tensors)dtype)) isinstancestr startswithhttpxgetcontentopenreadbytesr+feature_extractorrrtorchTensorcpunumpyr torchcodecdecoders AudioDecoderget_all_samplesdata sample_ratedictcopyrpopr torchaudiorM ImportErrorresamplerndarray from_numpy TypeErrorlenr!rPto) r5r:fr[r__audio_samples_array_inputsin_sampling_rateF processeds r* preprocessz&AudioClassificationPipeline.preprocesss fc "  +v/@/@/L6DAII&$'&1VVXF& fe $ )?)?)M)MNF   &%,,/++- " $  &*"5"5"B"BC!'!7!7!9',,#)Nrr?)scorelabel) logitsr>r?topktolistziprBrCid2label) r5r{r0rAprobsscoresidsr_idlabelss r* postprocessz'AudioClassificationPipeline.postprocesss  )!((+33B7E ) +!((+335E!((+Ejj' jjl_bcikn_opQ[QVX[EDJJ,=,=,F,Fs,KLpp qs0C)NN)r1r>)__name__ __module__ __qualname____doc___load_processor_load_image_processor_load_feature_extractor_load_tokenizerr3rrkrYrRrerlistr<rFrwr|r __classcell__)r8s@r*r.r.Bs}2O!"OL"2rzzE1C7$>"2#"2RVW[\_ad\dWeRf"2H*,IVr9r.)rtypingrrTr^rutilsrrrrr baser r models.auto.modeling_autor get_loggerrloggerrYintrkr+r.ryr9r*rs uu4X   H %!%!! !H,4HI@(@J@r9