Recherche avancée

Sur d’autres sites (10614)

• Nginx rtmp module - on_publish fires multiple time instead of once

  29 juillet 2017, par Stephen Wright

  This is copy and pasted from the bug report I created on the rtmp-module by Arut, I am not completely sure if it is a bug or me not understanding how the module works, I have read the whole directives of module as from https://github.com/arut/nginx-rtmp-module/wiki/Directives

  Proper explanation, if code is not displayed properly I will edit and fix

  Hi, been using the module and finding it very very good !

  Think I have found a issue though, although it may be me misunderstanding the directives.

  Essentially I wish to fire a script (/usr/local/bin/make_thumbnail.sh) which creates a thumbnail automatically from a stream (using ffmpeg), the idea is to have this done for every stream as soon as it is published in order to create a function a bit like twitch tv where the streamer will not have to specify any thumbnail image, authenticated users simply start a stream (which will later be authenticated but is not yet) The script does also write data into the database however this stage works fine and I don’t believe the issue is related, if I comment out these lines then the thumbnail creation still works and my issue continues.

  Initially this was done using the "exec" command as I believe I mis-read the documentation and I believe the exec command doesn’t work for my problem as ". When publishing stops the process is terminated." does this mean it will continually execute until stream stops ?

  I have started using the exec_publish command to try and fix this issue however the same issue seems to occur. The entire script repeats approximately every 15-17 seconds, a new thumbnail is created and a new database entry is create with all the correct information.

  Below is the nginx.conf line. Please ignore if indentation is incorrect couldn’t see a way to indent blocks of code and it’s late here, assume all code is indented correctly unless you believe that could be the issue in which case I will post it indented as early as I can.

  application live {
  
  allow play all;
  
  live on;
  
  record all;
  
  record_path /var/stream/video_recordings/;
  
  record_unique on; 
  
  hls on;
  
  hls_nested on;
  
  hls_path /var/stream/HLS/live;
  
  hls_fragment 10s;
  
  
  
  #on publish create thumbnail using first second of stream and save in 
  
  /var/stream/video_recordings/thumbnails
  
  exec_publish usr/local/bin/make_thumbnail.sh $name;

  The rest can be pasted or attached if needed but is working nginx config for rtmp + website

  The most simple version of the make_thumbnail..sh is pasted below, I have omitted the variables that I have used for database entryys obviously but as the script works without fail from terminal I believe this to be an nginx issue (if I run the command manually under the nginx user e.g. sudo -u nginx /usr/local/bin/make_thumbnail.sh with a name the same as any running stream, it works and only executes once as would expect, all permissions in script are ok and tested.

  make_thumbnail.sh

  #!/bin/bash
  
  
  
  TIME=$(date +%s)
  
  NAME=$1 
  
  echo "time: "
  
  FILENAME=${TIME}_${NAME}
  
  
  
  ffmpeg -i rtmp://192.168.0.98:1935/live/$1 -vframes 1 -s 150x150 -ss 10 -
  
  strftime 1 /var/stream/video_recordings/thumbnails/"$FILENAME.jpg";
  
  
  
  #Writes path to video into database
  
  mysql --user=$DB_USER --password=$DB_PASSWD $DB_NAME << EOF
  
  INSERT INTO $TABLE3 (thumbnailfile) VALUES ('$FILENAME');
  
  set @last_id_in_thumbnails = LAST_INSERT_ID();
  
  INSERT INTO $TABLE (created_at, updated_at, thumnailID) VALUES 
  
  (NOW(),NOW(),@last_id_in_thumbnails);
  
  SET @last_id_in_livestreams = LAST_INSERT_ID();
  
  INSERT INTO $TABLE2 (created_at, updated_at, filename,liveID) VALUES 
  
  (NOW(),NOW(),'$FILENAME',@last_id_in_livestreams); 
  
  EOF

  I have not got the nginx rtmp logs installed, I can obviously do this however some of the logs appear in the nginx error.log, strangely the latest stream I tried did not update in the access log, however I think this is because I did not attempt to connect to it via any method. I don’t fully understand the error.log, in my stupidity I decided to use nginx with which I am quite inexperienced and I am finding it very difficult to troubleshoot this issue, it appears to me that as part of the RTMP protocol or my streaming software (OBS) is either directly pinging the rtmp stream or is being pinged by the server to ensure the connection is still there. And this ping is

  I have left a stream running from approx 4 minutes without interacting with the server, streaming software, computer running the stream, I have ensured the internet connection is constant as my first though was the connection dropped, however on inspecting the database the executing is done always after at least 11 seconds however usually this is 16, I can’t seem to figure out how to select the closest dates from the database however there has been at least a few 17 second differences (potentially when
  I am unsure if this is an issue or if it is intended behavior but I do require this to finish a university degree, I’m not asking for answers but if it is a legitimate issue then I would be happy to spend as much time I can commit to it if some insight into what is causing it, or if there is a workaround I believe it should be documented somewhere, I have googled into making any exec commands run only once on publish

  I can’t seem to pinpoint where in the log the issue is happening however think it is something to do with the below exceprts I would attach the file but can’t seem to select all lines after the timestamp upon starting a stream

  2017/07/26 18:17:35 [info] 1451#0: *2229 exec: starting managed child 
  
  'ffmpeg', client: 192.168.0.78, server: 0.0.0.0:1935
  
  2017/07/26 18:17:35 [info] 1451#0: *2412 client connected '192.168.0.98'
  
  2017/07/26 18:17:35 [info] 1451#0: *2412 connect: app='live' args='' 
  
  flashver='LNX 9,0,124,2' swf_url='' tc_url='rtmp://192.168.0.98:1935/live' 
  
  page_url='' acodecs=4071 vcodecs=252 object_encoding=0, client: 
  
  192.168.0.98, server: 0.0.0.0:1935
  
  2017/07/26 18:17:35 [info] 1451#0: *2412 createStream, client: 192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  2017/07/26 18:17:35 [info] 1451#0: *2412 play: name='newname' args='' 
  
  start=-2000 duration=0 reset=0 silent=0, client: 192.168.0.98, server:  
  
  0.0.0.0:1935
  
  2017/07/26 18:17:36 [info] 1451#0: *2410 recv() failed (104: Connection  
  
  reset by peer), client: 192.168.0.98, server: 0.0.0.0:1935
  
  2017/07/26 18:17:36 [info] 1451#0: *2410 disconnect, client: 192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  2017/07/26 18:17:36 [info] 1451#0: *2410 deleteStream, client: 192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  2017/07/26 18:17:36 [notice] 1451#0: signal 17 (SIGCHLD) received
  
  2017/07/26 18:17:36 [notice] 1451#0: unknown process 10487 exited with code 
  
  0
  
  2017/07/26 18:17:36 [info] 1451#0: *2229 exec: child 10487 exited; ignoring, 
  
  client: 192.168.0.78, server: 0.0.0.0:1935
  
  
  
  ver: 0.0.0.0:1935
  
  2017/07/26 18:17:41 [info] 1451#0: *2229 exec: starting managed child 
  
  'usr/local/bin/make_thumbnail.sh', client: 192.168.0.78, server:  
  
  0.0.0.0:1935
  
  2017/07/26 18:17:41 [info] 1451#0: *2413 client connected '192.168.0.98'
  
  2017/07/26 18:17:41 [info] 1451#0: *2413 connect: app='live' args='' 
  
  flashver='LNX 9,0,124,2' swf_url='' tc_url='rtmp://192.168.0.98:1935/live' 
  
  page_url='' acodecs=4071 vcodecs=252 object_encoding=0, client: 
  
  192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  2017/07/26 18:17:41 [info] 1451#0: *2413 createStream, client: 192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  2017/07/26 18:17:41 [info] 1451#0: *2413 play: name='newname' args='' 
  
  start=-2000 duration=0 reset=0 silent=0, client: 192.168.0.98, server: 
  
  0.0.0.0:1935
  
  2017/07/26 18:17:43 [info] 1451#0: *2229 exec: starting managed child 
  
  'ffmpeg', 
  
  client: 192.168.0.78, server: 0.0.0.0:1935
  
  2017/07/26 18:17:43 [info] 1451#0: *2414 client connected '192.168.0.98'
  
  2017/07/26 18:17:43 [info] 1451#0: *2414 connect: app='live' args='' 
  
  flashver='LNX 9,0,124,2' swf_url='' tc_url='rtmp://192.168.0.98:1935/live' 
  
  page_url='' acodecs=4071 vcodecs=252 object_encoding=0, client: 
  
  192.168.0.98, 
  
  server: 0.0.0.0:1935
  
  @

• How to http stream video from a frequently updated image

  27 avril 2017, par alez

  How can I obtain an HTTP video stream from a single image file that is frequently updated (every 50ms) ?

  The file is on a Windows 7 machine, I can use C# but I can also send a potential stream to a linux machine.

  I would try whith vlc and the fake module, but it seems not more supported. I’ve tried also with a pipe from ffmpeg (also over an udp localhost stream) but it doesn’t work.

• QTableWidget and QProcess - update table based on multiple process results

  9 mars 2017, par Spencer

  I have a python program that runs through a QTableWidget and for each item it runs a QProcess (an FFMPEG process to be exact). What I’m trying to do is update the "parent" cell when the process completes. Right now there is a for loop that goes through each row and launches a process for each, and connects the finished signal of that process to a "finished" function, which updates the QTableWidget cell. I’m just having trouble properly telling the function WHICH sell to update - right now I am passing it the index of the current row (seeing as it is being spawned by the for loop) but what happens is by the time the processes start to finish it will only get the last row in the table... I’m quite new to Python and PyQt so it is possible there is some fundamental thing I have wrong here !

  I tried passing the actual QTabelWidgetItem instead of the index but I got this error : "RuntimeError : wrapped C/C++ object of type QTableWidgetItem has been deleted"

  My code, the function "finished" and line #132 are the relevant ones :

  import sys, os, re
  
  from PyQt4 import QtGui, QtCore
  
  
  
  class BatchTable(QtGui.QTableWidget):
  
      def __init__(self, parent):
  
          super(BatchTable, self).__init__(parent)
  
          self.setAcceptDrops(True)
  
          self.setColumnCount(4)
  
          self.setColumnWidth(1,50)
  
          self.hideColumn(3)
  
          self.horizontalHeader().setStretchLastSection(True)
  
          self.setHorizontalHeaderLabels(QtCore.QString("Status;Alpha;File;Full Path").split(";"))
  
  
  
          self.doubleClicked.connect(self.removeProject)
  
  
  
      def removeProject(self, myItem):
  
          row = myItem.row()
  
          self.removeRow(row)
  
  
  
      def dragEnterEvent(self, e):
  
          if e.mimeData().hasFormat('text/uri-list'):
  
              e.accept()
  
          else:
  
              print "nope"
  
              e.ignore()
  
  
  
      def dragMoveEvent(self, e):
  
          e.accept()
  
  
  
      def dropEvent(self, e):
  
          if e.mimeData().hasUrls:
  
              for url in e.mimeData().urls():
  
                  chkBoxItem = QtGui.QTableWidgetItem()
  
                  chkBoxItem.setFlags(QtCore.Qt.ItemIsUserCheckable | QtCore.Qt.ItemIsEnabled)
  
                  chkBoxItem.setCheckState(QtCore.Qt.Unchecked)
  
  
  
                  rowPosition = self.rowCount()
  
                  self.insertRow(rowPosition)
  
                  self.setItem(rowPosition, 0, QtGui.QTableWidgetItem("Ready"))
  
                  self.setItem(rowPosition, 1, chkBoxItem)
  
                  self.setItem(rowPosition, 2, QtGui.QTableWidgetItem(os.path.split(str(url.toLocalFile()))[1]))
  
                  self.setItem(rowPosition, 3, QtGui.QTableWidgetItem(url.toLocalFile()))
  
                  self.item(rowPosition, 0).setBackgroundColor(QtGui.QColor(80, 180, 30))
  
  
  
  class ffmpegBatch(QtGui.QWidget):
  
      def __init__(self):
  
          super(ffmpegBatch, self).__init__()
  
          self.initUI()
  
  
  
      def initUI(self):
  
  
  
          self.edit = QtGui.QTextEdit()
  
  
  
          cmdGroup = QtGui.QGroupBox("Commandline arguments")
  
          fpsLbl = QtGui.QLabel("FPS:")
  
          self.fpsCombo = QtGui.QComboBox()
  
          self.fpsCombo.addItem("29.97")
  
          self.fpsCombo.addItem("23.976")
  
          hbox1 = QtGui.QHBoxLayout()
  
          hbox1.addWidget(fpsLbl)
  
          hbox1.addWidget(self.fpsCombo)
  
          cmdGroup.setLayout(hbox1)
  
  
  
          saveGroup = QtGui.QGroupBox("Output")
  
          self.outputLocation = QtGui.QLineEdit()
  
          self.browseBtn = QtGui.QPushButton("Browse")
  
          saveLocationBox = QtGui.QHBoxLayout()
  
          # Todo: add "auto-step up two folders" button
  
          saveLocationBox.addWidget(self.outputLocation)
  
          saveLocationBox.addWidget(self.browseBtn)
  
          saveGroup.setLayout(saveLocationBox)
  
  
  
          runBtn = QtGui.QPushButton("Run Batch Transcode")
  
  
  
          mainBox = QtGui.QVBoxLayout()
  
          self.table = BatchTable(self)
  
          # TODO: add "copy from clipboard" feature
  
          mainBox.addWidget(self.table)
  
          mainBox.addWidget(cmdGroup)
  
          mainBox.addWidget(saveGroup)
  
          mainBox.addWidget(runBtn)
  
          mainBox.addWidget(self.edit)
  
  
  
          self.setLayout(mainBox)
  
          self.setGeometry(300, 300, 600, 500)
  
          self.setWindowTitle('FFMPEG Batch Converter')
  
  
  
          # triggers/events
  
          runBtn.clicked.connect(self.run)
  
  
  
      def RepresentsInt(self, s):
  
          try:
  
              int(s)
  
              return True
  
          except ValueError:
  
              return False
  
  
  
      def run(self):
  
          if (self.outputLocation.text() == ''):
  
              return
  
          for projIndex in range(self.table.rowCount()):
  
              # collect some data
  
              ffmpeg_app = "C:\\Program Files\\ffmpeg-20150702-git-03b2b40-win64-static\\bin\\ffmpeg"
  
              frameRate = self.fpsCombo.currentText()
  
              inputFile = self.table.model().index(projIndex,3).data().toString()
  
              outputPath = self.outputLocation.text()
  
              outputPath = outputPath.replace("/", "\\")
  
  
  
              # format the input for ffmpeg
  
              # find how the exact number range, stored as 'd'
  
              imageName = os.path.split(str(inputFile))[1]
  
              imageName, imageExt = os.path.splitext(imageName)
  
              length = len(imageName)
  
              d = 0
  
              while (self.RepresentsInt(imageName[length-2:length-1]) == True):
  
                  length = length-1
  
                  d = d+1
  
              inputPath = os.path.split(str(inputFile))[0]
  
              inputFile = imageName[0:length-1]
  
              inputFile = inputPath + "/" + inputFile + "%" + str(d+1) + "d" + imageExt
  
              inputFile = inputFile.replace("/", "\\")
  
  
  
              # format the output
  
              outputFile = outputPath + "\\" + imageName[0:length-2] + ".mov"
  
  
  
  
  
              # build the commandline
  
              cmd = '"' + ffmpeg_app + '"' + ' -y -r ' + frameRate + ' -i ' + '"' + inputFile + '"' + ' -vcodec dnxhd -b:v 145M -vf colormatrix=bt601:bt709 -flags +ildct ' + '"' + outputFile + '"'
  
  
  
              # launch the process
  
              proc = QtCore.QProcess(self)
  
              proc.finished.connect(lambda: self.finished(projIndex))
  
              proc.setProcessChannelMode(proc.MergedChannels)
  
              proc.start(cmd)
  
              proc.readyReadStandardOutput.connect(lambda: self.readStdOutput(proc, projIndex, 100))
  
              self.table.setItem(projIndex, 0, QtGui.QTableWidgetItem("Running..."))
  
              self.table.item(projIndex, 0).setBackgroundColor(QtGui.QColor(110, 145, 30))
  
  
  
      def readStdOutput(self, proc, projIndex, total):
  
          currentLine = QtCore.QString(proc.readAllStandardOutput())
  
          currentLine = str(currentLine)
  
          frameEnd = currentLine.find("fps", 0, 15)
  
          if frameEnd != -1:
  
              m = re.search("\d", currentLine)
  
              if m:
  
                  frame = currentLine[m.start():frameEnd]
  
                  percent = (float(frame)/total)*100
  
                  print "Percent: " + str(percent)
  
                  self.edit.append(str(percent))
  
                  self.table.setItem(projIndex, 0, QtGui.QTableWidgetItem("Encoded: " + str(percent) + "%"))
  
  
  
      def finished(self, projIndex):
  
          # TODO: This isn't totally working properly for multiple processes (seems to get confused)
  
          print "A process completed"
  
          print self.sender().readAllStandardOutput()
  
          if self.sender().exitStatus() == 0:
  
              self.table.setItem(projIndex, 0, QtGui.QTableWidgetItem("Encoded"))
  
              self.table.item(projIndex, 0).setBackgroundColor(QtGui.QColor(45, 145, 240))
  
  
  
  
  
  def main():
  
      app = QtGui.QApplication(sys.argv)
  
      ex = ffmpegBatch()
  
      ex.show()
  
      sys.exit(app.exec_())
  
  
  
  if __name__ == '__main__':
  
      main()

  (And yes I do know that my percentage update is totally wrong right now, still working on that...)