CameraEvents Service - Dahua Events to mqtt

trollmar · Feb 26, 2019

psycik said:
DO

Do you want to post your version to me, and I'll look at putting some of those changes in and dealing with the change in API (the 1/0 thing)
I should also make "do you want an image" configurable for if you're not using that function, they're pretty large to be chucking around mqtt for no reason.

Sure. But what kind of "version" do you need? My specific DahuaCam and Firmware?

psycik · Feb 26, 2019

trollmar said:
Sure. But what kind of "version" do you need? My specific DahuaCam and Firmware?

The version of code you're now running. And it would be useful to know the cam/firmware version - obviously between your cam and my nvr the API has changed.

trollmar · Feb 27, 2019

Hi,

Here are the specs.

Code:

Device TypeIPC-HDW5231R-Z 
Software Version2.460.0000.7.R, 
Build Date: 2017-03-06 
WEB Version3.2.1.427921 
ONVIF Version2.42 PTZ Version

Here my config.

Code:

[MQTT Broker]
IP: localhost
Port: 1883
#not currently supported
#Mqtt_Username = ''                      ;MQTT username, without qoutes
#Mqtt_Password = ''                      ;MQTT password, without qoutes
BaseTopic = 'CameraEvents'

[Cameras]
#camera1=Example1
camera2=Garten

#[Example1]
#host=192.168..108
#protocol=http
#name=NVR
#isNVR=True
#port=80
#user=USER
#pass=PASSWORD
#auth=digest
#events=VideoMotion,CrossLineDetection,AlarmLocal,VideoLoss,VideoBlind
#If the service doesn't get the channel titles (/cgi-bin/configManager.cgi?action=getConfig&name=ChannelTitle)
#then create a list in this format to prepopulate it.
#channels=0:cam1|1:cam2

[Garten]
host=xxx.xxx.xx.xx
protocol=http
name=IPC
port=80
isNVR=True
user=user
pass=pass
auth=digest
events=VideoMotion,CrossLineDetection,AlarmLocal,VideoLoss,VideoBlind
channels=1:Garten

IsNVR= true
This is obviously not right.

psycik · Feb 27, 2019

SO these are single cameras? Does it work any better with isNVR=False?

And have you got the python file you're running so that I can look at incorporating your changes you've had to make.

trollmar · Feb 28, 2019

Yes single Cams.
Just tryed with one of my cameras.

It runs. ..as far as I could say.

I made a Upstart Service so that it runs as Ubuntu service in Backround.

isNVR=False dosent make a differnce as I could say.

only changed your line 245 and rename all "ConfigParser" to "configparser" (Phyton3 related)
But Ill post all the code.

But...
today is carnival here. So no time.

On Saturday i could clone my working VM with CamerEvents and play a little bit more.

Best regards and a nice day or night ;-)

trollmar · Mar 2, 2019

Hi,

here is my modiefied CameraEvents.py

Code:

#!/usr/bin/python3 -u

"""
Attach event listener to Dahua devices
Borrowed code from https://github.com/johnnyletrois/dahua-watch
And https://github.com/SaWey/home-assistant-dahua-event
Author: PsycikNZ
"""


REQUIREMENTS = ['pycurl>=7']

import threading
import requests
import datetime
import re
import configparser
import logging
import os
import socket
import pycurl
import json
import time
import paho.mqtt.client as paho   # pip install paho-mqtt
import base64

version = "0.1.1"

mqttc = paho.Client("CameraEvents-" + socket.gethostname(), clean_session=True)

_LOGGER = logging.getLogger(__name__)
_LOGGER.setLevel(logging.DEBUG)
ch = logging.StreamHandler()
ch.setLevel(logging.DEBUG)

# create formatter
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')

# add formatter to ch
ch.setFormatter(formatter)
_LOGGER.addHandler(ch)



def setup( config):
    """Set up Dahua event listener."""
    #config = config.get(DOMAIN)

    dahua_event = DahuaEventThread(
        None,
        None
    )

    def _start_dahua_event(_event):
        dahua_event.start()

    def _stop_dahua_event(_event):
        dahua_event.stopped.set()

    return True

class DahuaDevice():
    #EVENT_TEMPLATE = "{protocol}://{host}:{port}/cgi-bin/eventManager.cgi?action=attach&channel=0&codes=%5B{events}%5D"
    EVENT_TEMPLATE = "{protocol}://{host}:{port}/cgi-bin/eventManager.cgi?action=attach&codes=%5B{events}%5D"
    CHANNEL_TEMPLATE = "{protocol}://{host}:{port}/cgi-bin/configManager.cgi?action=getConfig&name=ChannelTitle"
    SNAPSHOT_TEMPLATE = "{protocol}://{host}:{port}/cgi-bin/snapshot.cgi?channel={channel}"
    #SNAPSHOT_TEMPLATE = "{protocol}://{host}:{port}/cgi-bin/snapshot.cgi?chn={channel}"
    SNAPSHOT_EVENT = "{protocol}://{host}:{port}/cgi-bin/eventManager.cgi?action=attachFileProc&Flags[0]=Event&Events=%5B{events}%5D"
     #cgi-bin/snapManager.cgi?action=attachFileProc&Flags[0]=Event&Events=[VideoMotion%2CVideoLoss]   

    
    

    def __init__(self,  name, device_cfg, client, basetopic):
        if device_cfg["channels"]:
            self.channels = device_cfg["channels"]
        else:
            self.channels = {}
        self.Name = name
        self.CurlObj = None
        self.Connected = None
        self.Reconnect = None
        self.MQTTConnected = None
        self.user = device_cfg.get("user")
        self.password = device_cfg.get("pass")
        self.auth = device_cfg.get("auth")
        self.mqtt = device_cfg.get("mqtt")
        self.protocol  = device_cfg.get("protocol")
        self.host = device_cfg.get("host")
        self.port = device_cfg.get("port")
        self.alerts = device_cfg.get("alerts")
        self.client = client
        self.basetopic = basetopic

        #generate the event url
        self.url = self.EVENT_TEMPLATE.format(
            protocol=self.protocol,
            host=self.host,
            port=self.port,
            events=device_cfg.get("events")
            
        )
        
        
        self.isNVR = False
        try:
            # Get NVR parm, to get channel names if NVR
            self.isNVR = device_cfg.get("isNVR")

            if self.isNVR:
                #generate the channel url
                self.channelurl  = self.CHANNEL_TEMPLATE.format(
                    protocol=device_cfg.get("protocol"),
                    host=device_cfg.get("host"),
                    port=device_cfg.get("port")
                )
                self.snapshotevents = self.SNAPSHOT_EVENT.format(
                    protocol=self.protocol,
                    host=self.host,
                    port=self.port,
                    events=device_cfg.get("events")   
                )
                
                #RPCConnect(1)

                # get channel names here
                #table.ChannelTitle[0].Name=Garage
                response = requests.get(self.channelurl,auth=requests.auth.HTTPDigestAuth(self.user,self.password))
                for line in response.text.splitlines():
                    match = re.search(r'.\[(?P<index>[0-4])\]\..+\=(?P<channel>.+)',line)
                    if match:
                        _index = int(match.group("index"))
                        _channel = match.group("channel")
                        self.channels[_index] = _channel
            else:
                self.channels[0] = self.Name

        except Exception as e:
            _LOGGER.debug("Device " + name + " is not an NVR: " + str(e))
            _LOGGER.debug("Device " + name + " is not an NVR")


    def channelIsMine(self,channelname="",channelid=-1):
        for channel in self.channels:
            if channelname is not None and channelname == self.channels[channel]:
                return channel
            elif channelid > -1 and channel == channelid:
                return channel

        return -1

    #def ChannelList(self,channel):
    #    query_args = {"method":"configManager.getConfig",
    #         "params": {
    #             "name":"ChannelTitle"
    #         },
    #         "session":self.SessionID,
    #         "id":1}
    #
    #     print "[>] Get ChannelList:"
    #     url = '{}://{}:{}{}'.format(self.protocol, self.host, self.port, '/RPC2')
    #     response = requests.put(url,auth=requests.auth.HTTPDigestAuth(self.user,self.password),data=json.dumps(query_args))

    #     result = json.load(response.content)
    #     if not result['result']:
    #         print "Resp: ",result
    #         print "Error CMD: {}".format(self.string_request)
    #         return
    #     print result
    

    def SnapshotImage(self, channel, channelName, message):
        imageurl  = self.SNAPSHOT_TEMPLATE.format(
                host=self.host,
                protocol=self.protocol,
                port  = self.port,
                channel=channel
            )
        image = None
        _LOGGER.info("Snapshot Url: " + imageurl)
        try:
            if self.auth == "digest":
                image = requests.get(imageurl, stream=True,auth=requests.auth.HTTPDigestAuth(self.user, self.password)).content
            else:
                image = requests.get(imageurl, stream=True,auth=requests.auth.HTTPBasicAuth(self.user, self.password)).content
        
        
            if image is not None and len(image) > 0:
                #construct image payload
                #{{ \"message\": \"Motion Detected: {0}\", \"imagebase64\": \"{1}\" }}"
                imgpayload = base64.encodestring(image)
                msgpayload = json.dumps({"message":message,"imagebase64":imgpayload})
                #msgpayload = "{{ \"message\": \"{0}\", \"imagebase64\": \"{1}\" }}".format(message,imgpayload)
                
                self.client.publish(self.basetopic +"/{0}/Image".format(channelName),msgpayload)
        except Exception as ex:
            _LOGGER.error("Error sending image: " + str(ex))



    # Connected to camera
    def OnConnect(self):
        _LOGGER.debug("[{0}] OnConnect()".format(self.Name))
        self.Connected = True

    #disconnected from camera
    def OnDisconnect(self, reason):
        _LOGGER.debug("[{0}] OnDisconnect({1})".format(self.Name, reason))
        self.Connected = False

    #on receive data from camera.
    def OnReceive(self, data):
        #self.client.loop_forever()
        Data = data.decode("utf-8", errors="ignore")
        _LOGGER.debug("[{0}]: {1}".format(self.Name, Data))

        crossData = ""

        for Line in Data.split("\r\n"):
            if Line == "HTTP/1.1 200 OK":
                self.OnConnect()

            if not Line.startswith("Code="):
                 continue
            # elif (crossLineFlag or crossRegionFlag) and not Line.startswith("}"):
            #     crossData = crossData + Line
            #     continue
            # elif (crossLineFlag or crossRegionFlag) and Line.startswith("}"):
            #     crossData = crossData + Line
            #     crossLineFlag = False
            #     crossRegionFlag = False
            #    #process the data.
            
            Alarm = dict()
            Alarm["name"] = self.Name
            for KeyValue in Line.split(';'):
                Key, Value = KeyValue.split('=')
                Alarm[Key] = Value

            index =  int( Alarm["index"]         )
            if index in self.channels:
                Alarm["channel"] = self.channels[index]
            else:
                Alarm["channel"] = self.Name + ":" + str(index)

            #mqttc.connect(self.mqtt["IP"], int(self.mqtt["port"]), 60)
            if Alarm["Code"] == "VideoMotion" or Alarm["Code"] ==  "CrossRegionDetection" or Alarm["Code"] ==  "CrossLineDetection":
                _LOGGER.info("Video Motion received: "+  Alarm["name"] + " Index: " + Alarm["channel"] + " Code: " + Alarm["Code"])
                if Alarm["action"] == "Start":
                    if not self.client.connected_flag:
                        self.client.reconnect()
                    self.client.publish(self.basetopic +"/" + Alarm["Code"] + "/" + Alarm["channel"] ,"ON")
                    if self.alerts:
                        #possible new process:
                        #http://192.168.10.66/cgi-bin/snapManager.cgi?action=attachFileProc&Flags[0]=Event&Events=[VideoMotion%2CVideoLoss]
                        process = threading.Thread(target=self.SnapshotImage,args=(index+1,Alarm["channel"],"Motion Detected: {0}".format(Alarm["channel"])))
                        process.daemon = True                            # Daemonize thread
                        process.start()   
                else:
                    self.client.publish(self.basetopic +"/" + Alarm["Code"] + "/" + Alarm["channel"] ,"OFF")
            elif Alarm["Code"] ==  "CrossRegionDetection" or Alarm["Code"] ==  "CrossLineDetection":
                if Alarm["action"] == "Start":
                    crossData = json.loads(Alarm["data"])
                    _LOGGER.info(Alarm["Code"] + " received: " + Alarm["data"] )
                    if "Direction" not in crossData:
                        direction = "unknown"                       
                    else:
                        direction = crossData["Direction"]

                    region = crossData["Name"]
                    object = crossData["Object"]["ObjectType"]
                    regionText = "{} With {} in {} direction for {} region".format(Alarm["Code"],object,direction,region)

                    self.client.publish(self.basetopic +"/IVS/" + Alarm["channel"] ,regionText)
                    if self.alerts:
                            #possible new process:
                            #http://192.168.10.66/cgi-bin/snapManager.cgi?action=attachFileProc&Flags[0]=Event&Events=[VideoMotion%2CVideoLoss]
                            process = threading.Thread(target=self.SnapshotImage,args=(index+1,Alarm["channel"],"IVS: {0}: {1}".format(Alarm["channel"],regionText)))
                            process.daemon = True                            # Daemonize thread
                            process.start()
            else:
                _LOGGER.info("dahua_event_received: "+  Alarm["name"] + " Index: " + Alarm["channel"] + " Code: " + Alarm["Code"])
                self.client.publish(self.basetopic +"/" + Alarm["channel"] + "/" + Alarm["name"],Alarm["Code"])
            #2019-01-27 08:28:19,658 - __main__ - INFO - dahua_event_received: NVR Index: NVR:0 Code: CrossRegionDetection
            #2019-01-27 08:28:19,674 - __main__ - INFO - dahua_event_received: NVR Index: NVR:0 Code: CrossRegionDetection
            #2019-01-27 08:28:19,703 - __main__ - INFO - dahua_event_received: NVR Index: NVR:0 Code: CrossLineDetection
            #2019-01-27 08:28:19,729 - __main__ - INFO - dahua_event_received: NVR Index: NVR:0 Code: CrossRegionDetection
            #2019-01-27 08:28:19,743 - __main__ - INFO - dahua_event_received: NVR Index: NVR:0 Code: CrossLineDetection
            #mqttc.disconnect()
            #self.hass.bus.fire("dahua_event_received", Alarm)

    



class DahuaEventThread(threading.Thread):
    """Connects to device and subscribes to events"""
    Devices = []
    NumActivePlayers = 0

    CurlMultiObj = pycurl.CurlMulti()
    NumCurlObjs = 0
    

    def __init__(self,  mqtt, cameras):
        """Construct a thread listening for events."""

        self.basetopic = mqtt["basetopic"]

        self.client = paho.Client("CameraEvents-" + socket.gethostname(), clean_session=True)
        self.client.on_connect = self.mqtt_on_connect
        self.client.on_disconnect = self.mqtt_on_disconnect
        self.client.message_callback_add(self.basetopic +"/+/picture",self.mqtt_on_picture_message)
        self.client.message_callback_add(self.basetopic +"/+/alerts",self.mqtt_on_alert_message)
        
        self.client.will_set(self.basetopic +"/$online",False,0,True)
        

        self.alerts = True

        for device_cfg in cameras:

            device = DahuaDevice(device_cfg.get("name"), device_cfg, self.client,self.basetopic)
            self.Devices.append(device)

            CurlObj = pycurl.Curl()
            device.CurlObj = CurlObj

            CurlObj.setopt(pycurl.URL, device.url)
            
            CurlObj.setopt(pycurl.CONNECTTIMEOUT, 30)
            CurlObj.setopt(pycurl.TCP_KEEPALIVE, 1)
            CurlObj.setopt(pycurl.TCP_KEEPIDLE, 30)
            CurlObj.setopt(pycurl.TCP_KEEPINTVL, 15)
            if device.auth == 'digest':
                CurlObj.setopt(pycurl.HTTPAUTH, pycurl.HTTPAUTH_DIGEST)
                CurlObj.setopt(pycurl.USERPWD, "%s:%s" % (device.user, device.password))
            else:
                CurlObj.setopt(pycurl.HTTPAUTH, pycurl.HTTPAUTH)
                CurlObj.setopt(pycurl.USERPWD, "%s:%s" % (device.user, device.password))
            CurlObj.setopt(pycurl.WRITEFUNCTION, device.OnReceive)

            self.CurlMultiObj.add_handle(CurlObj)
            self.NumCurlObjs += 1

            _LOGGER.debug("Added Dahua device at: %s", device.url)

        #connect to mqtt broker
        
        self.client.connect(mqtt["IP"], int(mqtt["port"]), 60)
        
        self.client.loop_start()

        threading.Thread.__init__(self)
        self.stopped = threading.Event()


    def run(self):
        heartbeat = 0
        """Fetch events"""
        while 1:
            Ret, NumHandles = self.CurlMultiObj.perform()
            if Ret != pycurl.E_CALL_MULTI_PERFORM:
                break

        Ret = self.CurlMultiObj.select(1.0)
        while not self.stopped.isSet():
            # Sleeps to ease load on processor
            time.sleep(.05)
            heartbeat = heartbeat + 1
            if heartbeat % 1000 == 0:
                print ("heartbeat")
                _LOGGER.debug("Heartbeat")
                if not self.client.connected_flag:
                    self.client.reconnect()
                self.client.publish(self.basetopic +"/$heartbeat",str(datetime.datetime.now()))

            Ret, NumHandles = self.CurlMultiObj.perform()

            if NumHandles != self.NumCurlObjs:
                _, Success, Error = self.CurlMultiObj.info_read()

                for CurlObj in Success:
                    DahuaDevice = next(iter(filter(lambda x: x.CurlObj == CurlObj, self.Devices)), None)
                    if DahuaDevice.Reconnect:
                        _LOGGER.debug("Dahua Reconnect: %s", DahuaDevice.Name)
                        continue

                    DahuaDevice.OnDisconnect("Success")
                    DahuaDevice.Reconnect = time.time() + 5

                for CurlObj, ErrorNo, ErrorStr in Error:
                    DahuaDevice = next(iter(filter(lambda x: x.CurlObj == CurlObj, self.Devices)), None)
                    if DahuaDevice.Reconnect:
                        continue

                    DahuaDevice.OnDisconnect("{0} ({1})".format(ErrorStr, ErrorNo))
                    DahuaDevice.Reconnect = time.time() + 5

                for DahuaDevice in self.Devices:
                    if DahuaDevice.Reconnect and DahuaDevice.Reconnect < time.time():
                        self.CurlMultiObj.remove_handle(DahuaDevice.CurlObj)
                        self.CurlMultiObj.add_handle(DahuaDevice.CurlObj)
                        DahuaDevice.Reconnect = None
            #if Ret != pycurl.E_CALL_MULTI_PERFORM: break

    def mqtt_on_connect(self, client, userdata, flags, rc):
        if rc==0:
            _LOGGER.info("Connected to MQTT OK Returned code={0}".format(rc))
            self.client.connected_flag=True
            self.client.publish(self.basetopic +"/$online",True,0,False)
            self.client.publish(self.basetopic +"/$version",version)
            if self.alerts:
                state = "ON"
            else:
                state = "OFF"

            for device in self.Devices:
                device.alerts = state
                self.client.publish(self.basetopic +"" + device.Name + "/alerts/state",state)
            #self.client.subscribe(self.basetopic +"/#")
            #self.client.subscribe("CameraEventsPy/alerts")
            
        else:
            _LOGGER.info("Camera : {0}: Bad mqtt connection Returned code={1}".format("self.Name",rc) )
            self.client.connected_flag=False

    def mqtt_on_disconnect(self, client, userdata, rc):
        logging.info("disconnecting reason  "  +str(rc))
        self.client.connected_flag=False
        

    def mqtt_on_picture_message(self,client, userdata, msg):

        #if msg.payload.decode() == "Hello world!":
        _LOGGER.info("Picture Msg Received: Topic:{0} Payload:{1}".format(msg.topic,msg.payload))
        msgchannel = msg.topic.split("/")[1]
        for device in self.Devices:
            channel = device.channelIsMine(msgchannel)
            if channel > -1:
                _LOGGER.debug("Found Camera: {0} channel: {1}: Name:{2}".format(device.Name,channel,device.channels[channel]))
                device.SnapshotImage(channel,msgchannel,"Snap Shot Image")
                break
    
                    
    def mqtt_on_alert_message(self,client, userdata, msg):
        if msg.payload == 'ON':
            newState = True
        else:
            newState = False

        deviceName = msg.topic.split('/')[1]
        _LOGGER.info("Camera: {0}: Msg Received: Topic:{1} Payload:{2}".format(deviceName,msg.topic,msg.payload))
        for device in self.Devices:
            #channel = self.Devices[device].channelIsMine("Garage")
            if device.Name == deviceName:
                device.alerts = newState
                _LOGGER.info("Turning Alerts {0}".format( newState))
                self.client.publish(self.basetopic +"/" + device.Name + "/alerts/state",msg.payload)

    def mqtt_on_cross_message(self,client, userdata, msg):
        if msg.payload == 'ON':
            newState = True
        else:
            newState = False

        deviceName = msg.topic.split('/')[1]
        _LOGGER.info("Camera: {0}: Msg Received: Topic:{1} Payload:{2}".format(deviceName,msg.topic,msg.payload))
        for device in self.Devices:
            #channel = self.Devices[device].channelIsMine("Garage")
            if device.Name == deviceName:
                device.alerts = newState
                _LOGGER.info("Turning Alerts {0}".format( newState))
                self.client.publish(self.basetopic +"/" + device.Name + "/alerts/state",msg.payload)

if __name__ == '__main__':

    cameras = []
    cp = configparser.ConfigParser()
    _LOGGER.info("Loading config")
    filename = {"config.ini","conf/config.ini"}
    dataset = cp.read(filename)

    try:
        if len(dataset) != 1:
            raise ValueError( "Failed to open/find all files")
        camera_items = cp.items( "Cameras" )
        for key, camera_key in camera_items:
            #do something with path
            camera_cp = cp.items(camera_key)
            camera = {}
            #temp = cp.get(camera_key,"host")
            camera["host"] = cp.get(camera_key,'host')
            camera["protocol"] = cp.get(camera_key,'protocol')
            camera["isNVR"] = cp.get(camera_key,'isNVR')
            camera["name"] = cp.get(camera_key,'name')
            camera["port"] = cp.get(camera_key,'port')
            camera["user"] = cp.get(camera_key,'user')
            camera["pass"] = cp.get(camera_key,'pass')
            camera["auth"] = cp.get(camera_key,'auth')
            camera["events"] = cp.get(camera_key,'events')
            channels = {}
            try:
                channellist = cp.get(camera_key,'channels').split('|')
                for channel in channellist:
                    channelIndex = channel.split(':')[0]
                    channelName = channel.split(':')[1]
                    channels[int(channelIndex)] = channelName
                    
            except Exception as e:
                _LOGGER.error("Error Reading channel list:" + str(e))
            camera["channels"] = channels
            cameras.append(camera)

        mqtt = {}
        mqtt["IP"] = cp.get("MQTT Broker","IP")
        mqtt["port"] = cp.get("MQTT Broker","port")
        mqtt["basetopic"] = cp.get("MQTT Broker","BaseTopic")
        dahua_event = DahuaEventThread(mqtt,cameras)

        dahua_event.start()
    except Exception as ex:
        _LOGGER.error("Error starting:" + str(ex))

trollmar · Mar 3, 2019

Hi, a few questions about the MQTT topics.

heartbeat:

Code:

CameraEvents/out/$heartbeat

Very Cool Feature. Is it right that heartbeat has a subtopic level "/out"
I guess heartbeat belongs to the Script state. I would use is it to detect if the script is running.

$online:

Code:

CameraEvents/out/$online
CameraEvents/$online

I Have both. Why? I get Heartbeats but the state of both topics is always "False"!

outGarten/alerts/state:

Code:

CameraEvents/outGarten/alerts/state

Hi whats the purpose of this topic? Never changed since activation of the script.
But I guess there is a bug in the Code. Should be:

Code:

CameraEvents/out/Garten/alerts/state

Thx again for the script. Since I bought the Dahua cams I searched for possibility to get MQTT Messages instead of emails etc.

psycik · Mar 3, 2019

I’m not sure what the out one is. If one of your camera called out? Or has a channel called out?

And the heartbeat/online should only be on the CameraEvents high level.

Online should go true on start and gonfalse if the service is disconnected. But I must have missed a retain in it, as when subscribing to the service and it’s rhbbibgb it should show true. I’ll look at that.

The heartbeat is just the time, Just usfulnfor debugging really.

Regarding email etc. I use another service called mqttwarn from jpmens (not sure I’d ive linked to it in the readme). That can take an mqtt topic and push it out to various services, slack, pushover, email and a bunch of other.

As part of that, I wrote the image handling for mqttwarn for slack and pushover thatvwill take the images from my cameraevents and send notifications

trollmar · Mar 3, 2019

psycik said:
I’m not sure what the out one is. If one of your camera called out? Or has a channel called out?

And the heartbeat/online should only be on the CameraEvents high level.

Online should go true on start and gonfalse if the service is disconnected. But I must have missed a retain in it, as when subscribing to the service and it’s rhbbibgb it should show true. I’ll look at that.

Hi,

..no right now just one Camera in CamerEvents.
The Channel Name Called "Garten" the Cam Name is also "Garten". I delete my retained messages. Some duplicates are now gone. My fault sorry

Code:

[MQTT Broker]
IP: localhost
Port: 1883
#not currently supported
#Mqtt_Username = ''                      ;MQTT username, without qoutes
#Mqtt_Password = ''                      ;MQTT password, without qoutes
BaseTopic = CameraEvents/out

[Cameras]
camera2=Garten



[Garten]
host=192.168.xx.xxx
protocol=http
name=Garten
port=80
isNVR=False
user=user
pass=pass
auth=digest
events=VideoMotion,CrossLineDetection,AlarmLocal,VideoLoss,VideoBlind
channels=1:Garten

My Basetopic is "CameraEvents/out"
But the "problem" should be the same with different BaseTopics:
"CameraEvents/outGarten/alerts/state"
or "CameraEventsGarten/alerts/state"

greetz

psycik · Mar 3, 2019

Hmm for Online/Heartbeat I do post:
self.basetopic +"/$online"
self.basetopic +"/$heartbeat"

Ahh Found it:
self.client.publish(self.basetopic +"" + device.Name + "/alerts/state",state) (line 415

trollmar · Mar 3, 2019

Heartbeat and Online works as aspected.
Except of the retain part of $online .

I don't get any MQTT Messages from "CameraEvents/outGarten/alerts/state"
Glad you found the code. But whats the purpose?

trollmar · Mar 3, 2019

psycik said:
Ahh Found it:
self.client.publish(self.basetopic +"" + device.Name + "/alerts/state",state) (line 415

so should be
self.client.publish(self.basetopic + "/" +"" + device.Name + "/alerts/state",state) ???

pcunite · Apr 5, 2019

psycik said:
I had a similar service that was windows (c#), but most of my gear had moved to docker/python so I was keen to re-write it as I learnt python more.

Do you have a C# version you can share?

I would like to see an example of listening for a CrossLineDetection (TripWire) event, then grabbing the resulting snapshot image and video file.

psycik · Apr 5, 2019

pcunite said:
Do you have a C# version you can share?

I would like to see an example of listening for a CrossLineDetection (TripWire) event, then grabbing the resulting snapshot image and video file.

It was pretty unstable. Quite messy, and never got it to the point where I could release it.

And after switching to python it worked much more reliably

Ole · May 21, 2019

hi psycik,

seems to be the missing part for my Dahua integration.
Is it possible to get the docker image over dockerhub? Would likte to run it on my synology nas.

Regards, Sven

psycik · May 21, 2019

W

Ole said:
hi psycik,

seems to be the missing part for my Dahua integration.
Is it possible to get the docker image over dockerhub? Would likte to run it on my synology nas.

Regards, Sven

what architecture does the nas use? arm32, arm64 or amd64?

Ole · May 22, 2019

Hi,
I am running a DS718+ which is X64 architecture.

Regards
Sven

psycik · May 22, 2019

Try this then: Docker Hub
I've only pushed the amd64 version.
Are you sure it's not arm64?

Ole · May 22, 2019

Thx.
The nas is equipped with an Celeron j3455, so I assume x64 is right.

Tried your docker image, but unfortunately the container does not start.

Regards
Sven

psycik · May 22, 2019

Ole said:
Thx.
The nas is equipped with an Celeron j3455, so I assume x64 is right.

Tried your docker image, but unfortunately the container does not start.

Regards
Sven

Can you post the model of the nas....or another container you use. I should have amd64, arm32v6 (rPi3) and arm64x7 (Odroid C2). hopefully one of those is usable.

CameraEvents Service - Dahua Events to mqtt

n3wb

Getting the hang of it

n3wb

Getting the hang of it

n3wb

n3wb

n3wb

Getting the hang of it

n3wb

Getting the hang of it

n3wb

n3wb

Getting the hang of it

Getting the hang of it

n3wb

Getting the hang of it

n3wb

Getting the hang of it

n3wb

Getting the hang of it