Is there an equivalent input.harbor for video?

[gavin2812]

Hi all,

Apologies if I have missed it, but is there an equivalent of input.harbor but for video streams?

I was looking to create a simple "play main live video stream and if main stream fails, play backup live stream", kind of along these lines:

live = input.ffmpeg("http://livestream/index.m3u8")
emergency = input.ffmpeg("http://backupstream/index.m3u8")

# fallback
input = fallback(track_sensitive=false,
                 [live,emergency])
                
url1 = "rtmp://outputstream"   
# output 1       
enc = %ffmpeg(format="flv",
        %audio.copy,
        %video.copy)
output.url(fallible=true, url=url1, enc, input)

Is this currently possible?

P.S. I tried the code above and it plays the main stream, but if the main stream is disconnected, the code exits.

Thanks in advance.

[gavin2812]

Interestingly I just re-read the output when it exits and it looks like it does actually try and switch, but I get this:

2023/06/06 01:23:34 [switch_0:3] Switch to input.ffmpeg_0.
[http @ 0x7fce2c391100] HTTP error 404 Not Found
[hls @ 0x7fce20002c80] keepalive request failed for 'http://livestream/index.m3u8' with error: 'Server returned 404 Not Found' when parsing playlist
[http @ 0x7fce2df67940] HTTP error 404 Not Found
[hls @ 0x7fce20002c80] Failed to reload playlist 0
[http @ 0x7fce2db99200] HTTP error 404 Not Found
[hls @ 0x7fce20002c80] Failed to reload playlist 0
2023/06/06 01:40:50 [input.ffmpeg_0:2] Feeding failed: Ffmpeg_decoder.End_of_file
2023/06/06 01:40:50 [switch_0:3] Switch to input.ffmpeg_1 with forgetful transition.
2023/06/06 01:40:50 [clock.main:2] We must catchup 41.09 seconds!
[http @ 0x7fce20167c40] HTTP error 404 Not Found
[hls @ 0x7fce24002c80] skipping 4 segments ahead, expired from playlists
[flv @ 0x7fce2c004dc0] Failed to update header with correct duration.
[flv @ 0x7fce2c004dc0] Failed to update header with correct filesize.
2023/06/06 01:40:50 [output.url:2] Error while encoding data: Avutil.Error(End of file)
2023/06/06 01:40:50 [output.url:3] Will try again in 2.00 seconds.
2023/06/06 01:40:50 [input.ffmpeg_1:3] Buffer overrun: Dropping 19.11s. Consider increasing the max buffer size!
2023/06/06 01:40:50 [input.ffmpeg_1:2] Feeding failed: File "stream/generator.ml", line 78, characters 4-10: Assertion failed
2023/06/06 01:40:50 [output.url:3] Source failed (no more tracks) stopping output...
2023/06/06 01:40:50 [switch_0:3] Switch to input.ffmpeg_1.
2023/06/06 01:40:50 [clock.main:2] Source output.url failed while streaming: Invalid_argument("option is None")!
2023/06/06 01:40:50 [clock.main:2] Raised at Stdlib.invalid_arg in file "stdlib.ml", line 30, characters 20-45
2023/06/06 01:40:50 [clock.main:2] Called from Stdlib__Option.get in file "option.ml" (inlined), line 21, characters 41-69
2023/06/06 01:40:50 [clock.main:2] Called from Pipe_output.base#insert_metadata in file "outputs/pipe_output.ml", line 82, characters 31-51
2023/06/06 01:40:50 [clock.main:2] Called from Output.encoded#send_frame.output_chunks.f in file "outputs/output.ml", line 243, characters 24-76
2023/06/06 01:40:50 [clock.main:2] Called from Output.output#output in file "outputs/output.ml", line 174, characters 10-35
2023/06/06 01:40:50 [clock.main:2] Called from Clock.clock#end_tick.(fun) in file "clock.ml", line 300, characters 14-22
2023/06/06 01:40:50 [clock.main:2]
2023/06/06 01:40:50 [main:3] Shutdown started!

From my broad understanding of the above, it is trying to switch to the next stream, but I can't understand what the errors mean.

[smimram]

The error seems to indicate the the url http://livestream/index.m3u8 simply does not exist. Can you access it with a browser or wget?

[gavin2812]

Hi @smimram, thanks for your reply.

Yes, both URL's exist (in my example, live and emergency, where live is the main live video stream and emergency is the backup live video stream).

In the output copied above, it is indeed indicating that http://livestream/index.m3u8 does not exist because I have stopped it (to test it switches across to the emergency stream, which in the example would be http://backupstream/index.m3u8

So in the output, I have stopped http://livestream/index.m3u8 which I assume would indeed show that error (because it lo longer exists as I stopped it) and it shows in the log Switch to input.ffmpeg_1 which I assume is it trying to switch to the emergency url, but that never happens and it exits with the output shown.

The expected behaviour would be for it to correctly switch to the emergency stream if the live stream fails (which it seems it tries to do).

Is my understanding correct?

[gavin2812]

Hello,

I'm just revisiting this and have been able to get it working by switching input.ffmpeg to input.http and now it will switch between live and emergency streams.

The problem is that it takes quite a while to switch between inputs and also the RTMP disconnects while this happens.

Interestingly, switching back from emergency to live it happens immediately and does not drop the RMTP connection.

Does Liquidsoap have a better way for me to handle this? Ideally i'd like it to switch as quickly as happens and definitely not drop the RTMP stream between live and emergency, or am I doing something wrong?

Thanks in advance.

[toots]

I think some script extract would help 🙂

[gAlleb]

@gavin2812 Hi!

Something similar @Mikulskii have been doing with Nginx-rtmp-backup. It is slightly different approach but maybe this option will do for you. Worth a try. https://mikulski.rocks/backup-stream-for-24-7/

[gavin2812]

@gAlleb HI, thank you. Unfortunately for this particular use-case I cannot use the nginx configuration to make changes, I am hoping to do it using Liquidsoap. Thank you very much for your reply and suggestion.

@toots sure, below is the script and log. My main issue is that although now it works correctly (switches from main stream to backup and back again), when it switches to the backup stream the RTMP stream drops and take a very long time to reconnect (approx 30 seconds). What I am hoping to achieve is a seamless switch between the 'live' and 'emergency' streams, or at least that it does not disconnect the output RTMP stream when it happens. Thanks in advance!

settings.init.allow_root.set(true)

#Log Stuff
set ('log.file.path', '/home/test/video.log')
set ('log.level',5)

live = input.ffmpeg("http://livestream/index.m3u8")
emergency = input.ffmpeg("http://backupstream/index.m3u8")

# fallback
input = fallback(track_sensitive=false,
                 [live,emergency])
                 
url = "rtmp://outputstream"   

enc = %ffmpeg(
  format="flv",
  %audio(codec="aac", b="128k", samplerate=44100),
  %video(codec="libx264",width=1280, height=720,b="250k", preset="ultrafast")
)
output.url(fallible=true, url=url, enc, input)

Here is the log (this includes the script starting when the main live feed is already up, the disconnection of the live feed, the starting of the backup feed and then reconnecting the live feed again):

2023/10/16 11:37:23 >>> LOG START
2023/10/16 11:37:21 [main:3] Liquidsoap 2.1.4
2023/10/16 11:37:21 [main:3] Using: bytes=[distributed with OCaml 4.02 or above] posix-time2=65ec333 pcre=7.5.0 sedlex=3.0 menhirLib=20220210 curl=0.9.2 uri=4.2.0 memtrace=0.2.3 mem_usage=0.0.4 dtools=0.4.4 duppy=0.9.3 cry=0.6.8 mm=0.8.3 xmlplaylist=0.1.5 lastfm=0.3.3 ogg=0.7.3 ogg.decoder=0.7.3 vorbis=0.8.1 vorbis.decoder=0.8.1 opus=0.2.3 opus.decoder=0.2.3 speex=0.4.1 speex.decoder=0.4.1 mad=0.5.3 flac=0.3.1 flac.ogg=0.3.1 flac.decoder=0.3.1 dynlink=[distributed with Ocaml] lame=0.3.6 shine=0.2.3 frei0r=0.1.2 fdkaac=0.3.3 theora=0.4.0 theora.decoder=0.4.0 ffmpeg=1.1.8 bjack=0.1.6 alsa=0.3.0 ao=0.2.4 samplerate=0.1.6 taglib=0.3.10 ssl=0.5.13 magic=0.7.3 camomile=1.0.2 inotify=2.0-58-g1beb568 faad=0.5.2 soundtouch=0.1.9 portaudio=0.2.3 pulseaudio=0.1.6 ladspa=0.2.2 dssi=0.1.5 tsdl=v0.9.9 tsdl-ttf=0.5 tsdl-image=0.5 camlimages=4.2.6 camlimages.freetype=5.0.4 cohttp-lwt-unix=5.0.0 prometheus-app=1.2 srt.constants=0.3.0 srt.types=0.3.0 srt.stubs=0.3.0 srt.stubs.locked=0.3.0 srt=0.3.0 lo=0.2.0 gd=1.0a5 irc-client-unix=[unspecified]
2023/10/16 11:37:21 [clock:3] Using native (high-precision) implementation for latency control
2023/10/16 11:37:23 [lang:2] WARNING: "set" is deprecated and will be removed in future version. Please use `settings.path.to.key.set(value)`
2023/10/16 11:37:23 [lang:2] WARNING: "set" is deprecated and will be removed in future version. Please use `settings.path.to.key.set(value)`
2023/10/16 11:37:23 [frame:4] frame.audio.samplerate set to: 44100
2023/10/16 11:37:23 [frame:4] frame.video.framerate set to: 25
2023/10/16 11:37:23 [frame:4] frame.audio.channels set to: 2
2023/10/16 11:37:23 [frame:4] frame.video.default set to: false
2023/10/16 11:37:23 [frame:4] frame.midi.channels set to: 0
2023/10/16 11:37:23 [frame:4] frame.video.width set to: 1280
2023/10/16 11:37:23 [frame:4] frame.video.height set to: 720
2023/10/16 11:37:23 [frame:4] frame.audio.samplerate set to: 44100
2023/10/16 11:37:23 [frame:3] Using 44100Hz audio, 25Hz video, 44100Hz main.
2023/10/16 11:37:23 [frame:3] Video frame size set to: 1280x720
2023/10/16 11:37:23 [frame:3] Frame size must be a multiple of 1764 ticks = 1764 audio samples = 1 video samples.
2023/10/16 11:37:23 [frame:3] Targeting 'frame.duration': 0.04s = 1764 audio samples = 1764 ticks.
2023/10/16 11:37:23 [frame:3] Frames last 0.04s = 1764 audio samples = 1 video samples = 1764 ticks.
2023/10/16 11:37:23 [sandbox:3] Sandboxing disabled
2023/10/16 11:37:23 [video.converter:3] Using preferred video converter: ffmpeg.
2023/10/16 11:37:23 [audio.converter:3] Using samplerate converter: libsamplerate.
2023/10/16 11:37:23 [lifecycle:5] At stage: "Liquidsoap application start"
2023/10/16 11:37:23 [clock:4] Currently 1 clock(s) allocated.
2023/10/16 11:37:23 [clock.main:4] Starting 3 source(s)...
2023/10/16 11:37:23 [source:4] Source input.ffmpeg_0 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [input.ffmpeg_0:5] Activations changed: static=[input.ffmpeg_0], dynamic=[].
2023/10/16 11:37:23 [input.ffmpeg_0:5] Enabling caching mode: active source.
2023/10/16 11:37:23 [source:4] Source input.ffmpeg_1 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [input.ffmpeg_1:5] Activations changed: static=[input.ffmpeg_1], dynamic=[].
2023/10/16 11:37:23 [input.ffmpeg_1:5] Enabling caching mode: active source.
2023/10/16 11:37:23 [source:4] Source output.file_0 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [output.url:5] Clock is main[].
2023/10/16 11:37:23 [output.url:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:37:23 [output.url:4] Content type is {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [source:4] Source switch_0 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [input.ffmpeg_0:5] Activations changed: static=[input.ffmpeg_0], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:37:23 [input.ffmpeg_1:5] Activations changed: static=[input.ffmpeg_1], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:37:23 [switch_0:5] Activations changed: static=[output.url:output.url], dynamic=[].
2023/10/16 11:37:23 [output.url:5] Activations changed: static=[output.url], dynamic=[].
2023/10/16 11:37:23 [output.url:5] Enabling caching mode: active source.
2023/10/16 11:37:23 [threads:4] Created thread "clock_main" (1 total).
2023/10/16 11:37:23 [clock:4] Main phase starts.
2023/10/16 11:37:23 [threads:4] Created thread "generic queue #1" (1 total).
2023/10/16 11:37:23 [threads:4] Created thread "generic queue #2" (2 total).
2023/10/16 11:37:23 [threads:4] Created thread "non-blocking queue #1" (3 total).
2023/10/16 11:37:23 [threads:4] Created thread "non-blocking queue #2" (4 total).
2023/10/16 11:37:23 [clock.main:3] Streaming loop starts in auto-sync mode
2023/10/16 11:37:23 [clock.main:3] Delegating synchronisation to CPU clock
2023/10/16 11:37:23 [switch_0:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:37:23 [input.ffmpeg_0:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:37:23 [input.ffmpeg_1:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:37:23 [decoder.ffmpeg:4] ffmpeg recognizes "http://livestream/index.m3u8" as: audio: {codec: aac, 48000Hz, 2 channel(s)}, video: {codec: h264, 1280x720, yuv420p} and content-type: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:23 [video.text:3] Using camlimages implementation
2023/10/16 11:37:23 [decoder.ffmpeg:4] ffmpeg recognizes "http://backupstream/index.m3u8" as: audio: {codec: aac, 44100Hz, 2 channel(s)}, video: {codec: h264, 1280x720, yuv420p} and content-type: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:24 [input.ffmpeg_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [input.ffmpeg_1:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [switch_0:3] Switch to input.ffmpeg_0.
2023/10/16 11:37:24 [source:4] Source replay_metadata_0 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:24 [replay_metadata_0:5] Clock is main[].
2023/10/16 11:37:24 [replay_metadata_0:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:37:24 [replay_metadata_0:4] Content type is {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:37:24 [input.ffmpeg_0:5] Activations changed: static=[replay_metadata_0:switch_0:output.url:output.url, input.ffmpeg_0], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:37:24 [replay_metadata_0:5] Activations changed: static=[switch_0:output.url:output.url], dynamic=[].
2023/10/16 11:37:24 [replay_metadata_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [switch_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [input.ffmpeg_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [replay_metadata_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [switch_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:37:24 [input.ffmpeg_1:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:18 [clock.main:2] Too much latency! Resetting active sources...
2023/10/16 11:39:18 [replay_metadata_0:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:39:18 [source:4] Source replay_metadata_0 gets down.
2023/10/16 11:39:18 [input.ffmpeg_0:5] Activations changed: static=[input.ffmpeg_0], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:39:18 [output.url:3] Source failed (no more tracks) stopping output...
2023/10/16 11:39:18 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:18 [decoder.ffmpeg:4] ffmpeg recognizes "http://backupstream/index.m3u8" as: audio: {codec: aac, 44100Hz, 2 channel(s)}, video: {codec: h264, 1280x720, yuv420p} and content-type: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:39:19 [switch_0:3] Switch to input.ffmpeg_1.
2023/10/16 11:39:19 [source:4] Source replay_metadata_1 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:39:19 [replay_metadata_1:5] Clock is main[].
2023/10/16 11:39:19 [replay_metadata_1:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:39:19 [replay_metadata_1:4] Content type is {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:39:19 [input.ffmpeg_1:5] Activations changed: static=[replay_metadata_1:switch_0:output.url:output.url, input.ffmpeg_1], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:39:19 [replay_metadata_1:5] Activations changed: static=[switch_0:output.url:output.url], dynamic=[].
2023/10/16 11:39:19 [replay_metadata_1:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:19 [switch_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:19 [input.ffmpeg_1:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:19 [replay_metadata_1:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:19 [switch_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:39:20 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:22 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:24 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:26 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:28 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:30 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:32 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:34 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:36 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:38 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:40 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:42 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:44 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:46 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:48 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:50 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:52 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:54 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:56 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:39:58 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:00 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:02 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:04 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:06 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:08 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:10 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:12 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:14 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:16 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:19 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:21 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:23 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:25 [input.ffmpeg_0:4] Connection failed: Avutil.Error(Server returned 404 Not Found)
2023/10/16 11:40:27 [decoder.ffmpeg:4] ffmpeg recognizes "http://livestream/index.m3u8" as: audio: {codec: aac, 48000Hz, 2 channel(s)}, video: {codec: h264, 1280x720, yuv420p} and content-type: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:40:27 [input.ffmpeg_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:40:27 [switch_0:3] Switch to input.ffmpeg_0 with transition.
2023/10/16 11:40:27 [replay_metadata_1:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:27 [source:4] Source replay_metadata_1 gets down.
2023/10/16 11:40:27 [input.ffmpeg_1:5] Activations changed: static=[input.ffmpeg_1], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:40:27 [source:4] Source replay_metadata_2 gets up with content kind: {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:40:27 [replay_metadata_2:5] Clock is main[].
2023/10/16 11:40:27 [replay_metadata_2:5] Content kind: {audio=pcm(stereo),video=canvas,midi=none}, content type: {audio=pcm(stereo),video=canvas,midi=none}
2023/10/16 11:40:27 [replay_metadata_2:4] Content type is {audio=pcm(stereo),video=canvas,midi=none}.
2023/10/16 11:40:27 [input.ffmpeg_0:5] Activations changed: static=[replay_metadata_2:switch_0:output.url:output.url, input.ffmpeg_0], dynamic=[switch_0:output.url:output.url].
2023/10/16 11:40:27 [replay_metadata_2:5] Activations changed: static=[switch_0:output.url:output.url], dynamic=[].
2023/10/16 11:40:27 [replay_metadata_2:5] Got metadata at position 0: calling handlers...
2023/10/16 11:40:27 [switch_0:5] Got metadata at position 0: calling handlers...
2023/10/16 11:40:59 [main:3] Shutdown started!
2023/10/16 11:40:59 [lifecycle:5] At stage: "Liquidsoap core shutdown"
2023/10/16 11:40:59 [main:3] Waiting for main threads to terminate...
2023/10/16 11:40:59 [threads:4] Waiting for thread clock_main to shutdown
2023/10/16 11:40:59 [output.url:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:59 [source:4] Source output.url gets down.
2023/10/16 11:40:59 [switch_0:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:59 [source:4] Source switch_0 gets down.
2023/10/16 11:40:59 [input.ffmpeg_0:5] Activations changed: static=[replay_metadata_2:switch_0:output.url:output.url, input.ffmpeg_0], dynamic=[].
2023/10/16 11:40:59 [input.ffmpeg_1:5] Activations changed: static=[input.ffmpeg_1], dynamic=[].
2023/10/16 11:40:59 [replay_metadata_2:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:59 [source:4] Source replay_metadata_2 gets down.
2023/10/16 11:40:59 [input.ffmpeg_0:5] Activations changed: static=[input.ffmpeg_0], dynamic=[].
2023/10/16 11:40:59 [input.ffmpeg_1:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:59 [source:4] Source input.ffmpeg_1 gets down.
2023/10/16 11:40:59 [input.ffmpeg_0:5] Activations changed: static=[], dynamic=[].
2023/10/16 11:40:59 [source:4] Source input.ffmpeg_0 gets down.
2023/10/16 11:40:59 [clock.main:3] Streaming loop stopped.
2023/10/16 11:40:59 [threads:4] Thread "clock_main" terminated (0 remaining).
2023/10/16 11:40:59 [main:3] Main threads terminated.
2023/10/16 11:40:59 [lifecycle:5] At stage: "Liquidsoap scheduler shutdown"
2023/10/16 11:40:59 [threads:3] Shutting down scheduler...
2023/10/16 11:40:59 [threads:4] Thread "generic queue #1" terminated (3 remaining).
2023/10/16 11:40:59 [threads:4] Thread "generic queue #2" terminated (2 remaining).
2023/10/16 11:40:59 [threads:4] Thread "non-blocking queue #2" terminated (1 remaining).
2023/10/16 11:40:59 [threads:4] Thread "non-blocking queue #1" terminated (0 remaining).
2023/10/16 11:40:59 [threads:3] Scheduler shut down.
2023/10/16 11:40:59 [lifecycle:5] At stage: "Liquidsoap final cleanup"
2023/10/16 11:40:59 [main:3] Cleaning downloaded files...
2023/10/16 11:40:59 [main:3] Freeing memory...

[gavin2812]

Hi, I'm picking this back up again from a while back as I'd like to get it working.

My intention is to simply switch between a live and main (like autodj) stream without the output disconnecting.

I'm currently running 2.2.3

This is what I have at the moment:

settings.init.allow_root.set(true)

live = input.http("http://livestream/index.m3u8")
main = input.http("http://backupstream/index.m3u8")

# fallback
input = fallback(track_sensitive=false,
                 [live,main])
                 
url1 = "rtmp://output/live"   
# output 1       
enc = %ffmpeg(format="flv",
        %audio.copy,
        %video.copy)
output.url(fallible=true, url=url1, enc, input)

And this works, but this switch between the sources is nowhere near as seamless as it should be, it will switch between the main and live feeds OK, but then going back to the main feed it takes around 30 seconds.

Is there are better way to achieve what I am trying to do?

Thanks again in advance.

[Mikulskii]

Hi!
I use input.rtmp for this purpose and connect via OBS
https://www.liquidsoap.info/doc-2.2.3/reference.html#input.rtmp

So it will be like:
live = input.rtmp(listen=true, "rtmp://your_server_IP:1935/key")

You send a stream from OBS to the specified rtmp address and key (think of it yourself).
The default port for rtmp is 1935, make sure it is open in the firewall

If you are using nginx-rtmp, then listen=false and in the nginx config for the app you must specify play_restart on;
Like:

        application live {
            live on;
            record off;
            play_restart on;
            }

[gavin2812]

@Mikulskii thanks for taking the time to reply.

So I updated the code as follows:

settings.init.allow_root.set(true)

live = input.rtmp(id="live", listen=true, max_buffer=.10, "rtmp://rtmpserver:1935/live/live")
main = input.rtmp(id="main", listen=true, max_buffer=.10, "rtmp://rtmpserver:1935/live/main")

# fallback
input = fallback(track_sensitive=false,
                 [live,main])
                 
url1 = "rtmp://rtmpserver/live/output"   
# output 1       
enc = %ffmpeg(format="flv",
        %audio.copy,
        %video.copy)
output.url(fallible=true, url=url1, enc, input)

But now I get:

[rtmp @ 0x7f885e427000] Cannot open connection tcp://rtmpserver:1935?listen&listen_timeout=-1000&tcp_nodelay=0
[rtmp @ 0x7f885d827000] Cannot open connection tcp://rtmpserver:1935?listen&listen_timeout=-1000&tcp_nodelay=0
2024/09/03 09:46:19 [main:2] Decoding failed: Avutil.Error(Cannot assign requested address)
2024/09/03 09:46:19 [live:2] Decoding failed: Avutil.Error(Cannot assign requested address)

I know that both the RTMP input feeds are good because I have tested them in VLC and they play fine.

I also updated the nginx to add the code play_restart on; (the other bits were already there)

Any thoughts on what could be causing this?

Thanks in advance.

[Mikulskii]

You forgot to set the listen parameter to false (if the streams go to nginx first, then you don't need to listen),
try this:

live = input.rtmp(id="live", listen=false, max_buffer=.10, "rtmp://rtmpserver:1935/live/live")
main = input.rtmp(id="main", listen=false, max_buffer=.10, "rtmp://rtmpserver:1935/live/main") 

[gavin2812]

@Mikulskii Thanks! This now works as expected, I appreciate your help.

[Mikulskii]

Great! I was glad to help