Recherche avancée

Sur d’autres sites (9302)

• How to pipe each bitrate of ffmpeg output to a third party program ?

  6 janvier 2023, par Brainstorm

  My requirement is very simple. Any one can understand from below example,

  


  fmpeg -i ../original.mkv
  
-c:v h264 -c:a aac -f mpegts - | myprogam \
  
-c:v h264 -c:a aac -vf "scale=1280:720" -f mpegts - | myprogam \
  
-c:v h264 -c:a aac -vf "scale=854:480" -f mpegts - | myprogam

  


  I want to pass each version of output to a third party python program. Any help is highly appreciated.

  


  Thank you

  


• Pipe a HTTP response

  30 juillet 2014, par viperfx

  How do I pipe an HTTP response like in NodeJS. Here is the snippet I am using in NodeJS :

  request({
  
    url: audio_file_url,
  
  }).pipe(ffmpeg_process.stdin);

  How can I achieve the same result in Go ?

  I am trying to pipe a audio stream from HTTP into an FFmpeg process so that it converts it on the fly and returns the converted file back to the client.

  Just so its clear to everyone here is my source code so far :

  func encodeAudio(w http.ResponseWriter, req *http.Request) {
  
      path, err := exec.LookPath("youtube-dl")
  
      if err != nil {
  
          log.Fatal("LookPath: ", err)
  
      }
  
      path_ff, err_ff := exec.LookPath("ffmpeg")
  
      if err != nil {
  
          log.Fatal("LookPath: ", err_ff)
  
      }
  
  
  
      streamLink := exec.Command(path,"-f", "140", "-g", "https://www.youtube.com/watch?v=VIDEOID")
  
  
  
      var out bytes.Buffer
  
      streamLink.Stdout = &out
  
      cmdFF := exec.Command(path_ff, "-i", "pipe:0", "-acodec", "libmp3lame", "-f", "mp3", "-")
  
      resp, err := http.Get(out.String())
  
      if err != nil {
  
          log.Fatal(err)
  
      }
  
      // pr, pw := io.Pipe()
  
      defer resp.Body.Close()
  
      cmdFF.Stdin = resp.Body
  
      cmdFF.Stdout = w
  
      streamLink.Run()
  
      //get ffmpeg running in another goroutine to receive data
  
      errCh := make(chan error, 1)
  
      go func() {
  
          errCh <- cmdFF.Run()
  
      }()
  
  
  
      // close the pipeline to signal the end of the stream
  
      // pw.Close()
  
      // pr.Close()
  
  
  
      // check for an error from ffmpeg
  
      if err := <-errCh; err != nil {
  
          // ff error
  
      }
  
  }

  Error : 2014/07/29 23:04:02 Get : unsupported protocol scheme ""

• streaming data with ffmpeg using pipe - stream never starts

  9 novembre 2022, par tamirg

  Im fetching some video data, and trying to stream it using ffmpeg. what i do is create an ffmpeg process, set it to get info from '-', and then when i fetch the video data i write it to the process STDIN.

  


  My issue is that the steaming procces sometimes starts, and sometimes doesnt start. it really seems random (will add the ffmpeg logs at the end).
But if i save the entire data into a file, and then use ffplay on that file, it works perfectly fine, all the time.

  


  So im guessing something in the data is causing some issues with ffmpeg usage with pipe. The logs indicate that there are some issues with the DTS, but i dont know if thats the reason that stream never plays, and what can be done to fix that.

  


  I cant really understand the issue from the logs, but maybe they indicate what is the issue exactly ?

  


  logs :

  


  When the stream proccess doesnt start and doesnt work, those are the logs :

  


  [mpeg @ 0x7fc7b63ef840] Format mpeg probed with size=262144 and score=52
[mpeg @ 0x7fc7b63ef840] Before avformat_find_stream_info() pos: 6 bytes read:263756 seeks:0 nb_streams:0
[NULL @ 0x7fc7b63eec00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7fc7b63eec00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7fc7b63eec00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7fc7b63eec00] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7fc7b63eec00] Decoding VPS
[NULL @ 0x7fc7b63eec00] Main profile bitstream
[NULL @ 0x7fc7b63eec00] Decoding SPS
[NULL @ 0x7fc7b63eec00] Main profile bitstream
[NULL @ 0x7fc7b63eec00] Decoding VUI
[NULL @ 0x7fc7b63eec00] Decoding PPS
[extract_extradata @ 0x7fc7b63f2140] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7fc7b63f2140] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7fc7b63f2140] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7fc7b63f2140] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] Decoding VPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding SPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding VUI
[hevc @ 0x7fc7b63eec00] Decoding PPS
[hevc @ 0x7fc7b63eec00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] Decoding VPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding SPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding VUI
[hevc @ 0x7fc7b63eec00] Decoding PPS
[mpeg @ 0x7fc7b63ef840] Non-increasing DTS in stream 1: packet 3 with DTS 150119711008467, packet 4 with DTS 150119711008467
[mpeg @ 0x7fc7b63ef840] Non-increasing DTS in stream 1: packet 5 with DTS 150119711008469, packet 6 with DTS 150119711008469
[hevc @ 0x7fc7b63eec00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7fc7b63eec00] Decoding VPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding SPS
[hevc @ 0x7fc7b63eec00] Main profile bitstream
[hevc @ 0x7fc7b63eec00] Decoding VUI
[hevc @ 0x7fc7b63eec00] Decoding PPS


  


  After the last log line, nothing happens, and no more log lines appear.

  


  When the process actually starts and works fine, those are the logs :

  


  [mpeg @ 0x7f5475d69840] Format mpeg probed with size=524288 and score=52
[mpeg @ 0x7f5475d69840] Before avformat_find_stream_info() pos: 6 bytes read:526296 seeks:0 nb_streams:0
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 2 with DTS 150120249571596, packet 3 with DTS 150120249571596
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 4 with DTS 150120249571598, packet 5 with DTS 150120249571598
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 5 with DTS 150120249571598, packet 6 with DTS 150120249571598
[NULL @ 0x7f5475d68c00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7f5475d68c00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7f5475d68c00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7f5475d68c00] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[NULL @ 0x7f5475d68c00] Decoding VPS
[NULL @ 0x7f5475d68c00] Main profile bitstream
[NULL @ 0x7f5475d68c00] Decoding SPS
[NULL @ 0x7f5475d68c00] Main profile bitstream
[NULL @ 0x7f5475d68c00] Decoding VUI
[NULL @ 0x7f5475d68c00] Decoding PPS
[extract_extradata @ 0x7f5475d6c140] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7f5475d6c140] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7f5475d6c140] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[extract_extradata @ 0x7f5475d6c140] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] Decoding VPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding SPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding VUI
[hevc @ 0x7f5475d68c00] Decoding PPS
[hevc @ 0x7f5475d68c00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] Decoding VPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding SPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding VUI
[hevc @ 0x7f5475d68c00] Decoding PPS
[hevc @ 0x7f5475d68c00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] Decoding VPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding SPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding VUI
[hevc @ 0x7f5475d68c00] Decoding PPS
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 1 times
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 10 with DTS 150120249571825, packet 11 with DTS 150120249571825
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 4 times
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 15 with DTS 150120249571844, packet 16 with DTS 150120249571844
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 7 times
[mpeg @ 0x7f5475d69840] Non-increasing DTS in stream 1: packet 25 with DTS 150120249571878, packet 26 with DTS 150120249571878
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 7 times
[mpeg @ 0x7f5475d69840] DTS discontinuity in stream 0: packet 23 with DTS 150120249572205, packet 24 with DTS 150120249610965
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 35 times
[hevc @ 0x7f5475d68c00] nal_unit_type: 32(VPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 33(SPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 34(PPS), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] nal_unit_type: 19(IDR_W_RADL), nuh_layer_id: 0, temporal_id: 0
[hevc @ 0x7f5475d68c00] Decoding VPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding SPS
[hevc @ 0x7f5475d68c00] Main profile bitstream
[hevc @ 0x7f5475d68c00] Decoding VUI
[hevc @ 0x7f5475d68c00] Decoding PPS
[hevc @ 0x7f5475d68c00] nal_unit_type: 1(TRAIL_R), nuh_layer_id: 0, temporal_id: 0
    Last message repeated 8 times
[mpeg @ 0x7f5475d69840] max_analyze_duration 5000000 reached at 5056000 microseconds st:1
[mpeg @ 0x7f5475d69840] After avformat_find_stream_info() pos: 1428588 bytes read:1428588 seeks:0 frames:152
Input #0, mpeg, from 'pipe:':
  Duration: N/A, start: 1668002773.015456, bitrate: N/A


  


  The main issue, is that it sometimes works, sometimes doesnt work.

  


  The ffmpeg proccess is just created by using asyncio.create_subprocess_exec

  


  Every time i get a video data, i pass the data to the proccess by calling ffmpeg_process.stdin.write(data)

  


  I believe the issue is with the data, since with video data, the whole pipeline works for me. But i cannot understand from the ffmpeg logs what is the issue exactly.