CameraEvents Service - Dahua Events to mqtt

trollmar

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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?
 

trollmar

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
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

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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 ;-)
 
Last edited:

trollmar

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
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

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
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

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

n3wb
Joined
Feb 9, 2017
Messages
20
Reaction score
0
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

Young grasshopper
Joined
Jan 28, 2018
Messages
73
Reaction score
23
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
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

n3wb
Joined
Feb 5, 2018
Messages
8
Reaction score
0
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
W
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

n3wb
Joined
Feb 5, 2018
Messages
8
Reaction score
0
Hi,
I am running a DS718+ which is X64 architecture.

Regards
Sven
 

Ole

n3wb
Joined
Feb 5, 2018
Messages
8
Reaction score
0
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

Getting the hang of it
Joined
Dec 9, 2015
Messages
169
Reaction score
25
Location
Wellington, New Zealand
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.
 
Top