openhabforum.de

Code: Alles auswählen

cat /etc/openhab2/services/mqtt.cfg
#
# Define your MQTT broker connections here for use in the MQTT Binding or MQTT
# Persistence bundles. Replace <broker> with an ID you choose.
#

# URL to the MQTT broker, e.g. tcp://localhost:1883 or ssl://localhost:8883
MQTTBroker.url=tcp://localhost:1883

# Optional. Client id (max 23 chars) to use when connecting to the broker.
# If not provided a random default is generated.
#<broker>.clientId=<clientId>

# Optional. True or false. If set to true, allows the use of clientId values
# up to 65535 characters long. Defaults to false.
# NOTE: clientId values longer than 23 characters may not be supported by all
# MQTT servers. Check the server documentation.
#<broker>.allowLongerClientIds=false

# Optional. User id to authenticate with the broker.
#MQTTBroker.user=<nope>

# Optional. Password to authenticate with the broker.
#MQTTBroker.pwd=<nope>

# Optional. Set the quality of service level for sending messages to this broker.
# Possible values are 0 (Deliver at most once),1 (Deliver at least once) or 2
# (Deliver exactly once). Defaults to 0.
MQTTBroker.qos=0

# Optional. True or false. Defines if the broker should retain the messages sent to
# it. Defaults to false.
#<broker>.retain=<retain>

# Optional. True or false. Defines if messages are published asynchronously or
# synchronously. Defaults to true.
MQTTBroker.async=false

# Optional. Defines the last will and testament that is sent when this client goes offline
# Format: topic:message:qos:retained <br/>
#<broker>.lwt=<last will definition>

Code: Alles auswählen

cat /etc/openhab2/services/mqtt-eventbus.cfg
# Name of the broker as it is defined in the openhab.cfg. If this property is not available, no event bus MQTT binding will be created.
broker=MQTTBroker

# When available, all status updates which occur on the openHAB event bus are published to the provided topic. The message content will
# be the status. The variable ${item} will be replaced during publishing with the item name for which the state was received.
statePublishTopic=/messages/states/${item}

# When available, all commands which occur on the openHAB event bus are published to the provided topic. The message content will be the
# command. The variable ${item} will be replaced during publishing with the item name for which the command was received.
#commandPublishTopic=

# When available, all status updates received on this topic will be posted to the openHAB event bus. The message content is assumed to be
# a string representation of the status. The topic should include the variable ${item} to indicate which part of the topic contains the
# item name which can be used for posting the received value to the event bus.
#stateSubscribeTopic=

# When available, all commands received on this topic will be posted to the openHAB event bus. The message content is assumed to be a
# string representation of the command. The topic should include the variable ${item} to indicate which part of the topic contains the
# item name which can be used for posting the received value to the event bus.
commandSubscribeTopic=/messages/commands/${item}

Code: Alles auswählen

cat /etc/openhab2/services/mqtt.cfg
#
# Define your MQTT broker connections here for use in the MQTT Binding or MQTT
# Persistence bundles. Replace <broker> with an ID you choose.
#

# URL to the MQTT broker, e.g. tcp://localhost:1883 or ssl://localhost:8883
MQTTBroker.url=tcp://192.168.0.5:1883

# Optional. Client id (max 23 chars) to use when connecting to the broker.
# If not provided a default one is generated.
#<broker>.clientId=<clientID>

# Optional. User id to authenticate with the broker.
#MQTTBroker.user=<nope>

# Optional. Password to authenticate with the broker.
#MQTTBroker.pwd=<nope>

# Optional. Set the quality of service level for sending messages to this broker.
# Possible values are 0 (Deliver at most once),1 (Deliver at least once) or 2
# (Deliver exactly once). Defaults to 0.
#<broker>.qos=<qos>

# Optional. True or false. Defines if the broker should retain the messages sent to
# it. Defaults to false.
#MQTTBroker.retain=false

# Optional. True or false. Defines if messages are published asynchronously or
# synchronously. Defaults to true.
MQTTBroker.async=false

# Optional. Defines the last will and testament that is sent when this client goes offline
# Format: topic:message:qos:retained <br/>
#<broker>.lwt=<last will definition>

Code: Alles auswählen

cat /etc/openhab2/services/mqtt-eventbus.cfg
# Name of the broker as it is defined in the openhab.cfg. If this property is not available, no event bus MQTT binding will be created.
broker=MQTTBroker

# When available, all status updates which occur on the openHAB event bus are published to the provided topic. The message content will
# be the status. The variable ${item} will be replaced during publishing with the item name for which the state was received.
#statePublishTopic=

# When available, all commands which occur on the openHAB event bus are published to the provided topic. The message content will be the
# command. The variable ${item} will be replaced during publishing with the item name for which the command was received.
commandPublishTopic=/messages/commands/${item}

# When available, all status updates received on this topic will be posted to the openHAB event bus. The message content is assumed to be
# a string representation of the status. The topic should include the variable ${item} to indicate which part of the topic contains the
# item name which can be used for posting the received value to the event bus.
stateSubscribeTopic=/messages/states/${item}

# When available, all commands received on this topic will be posted to the openHAB event bus. The message content is assumed to be a
# string representation of the command. The topic should include the variable ${item} to indicate which part of the topic contains the
# item name which can be used for posting the received value to the event bus.
#commandSubscribeTopic=

Code: Alles auswählen

cat /etc/mosquitto/mosquitto.conf
# Place your local configuration in /etc/mosquitto/conf.d/
#
# A full description of the configuration file is at
# /usr/share/doc/mosquitto/examples/mosquitto.conf.example

persistence true
persistence_location /var/lib/mosquitto/

log_dest file /var/log/mosquitto/mosquitto.log

include_dir /etc/mosquitto/conf.d

allow_anonymous true

socket_domain ipv4

Code: Alles auswählen

UID: mqtt:broker:mosquitto
label: MQTT Broker
thingTypeUID: mqtt:broker
configuration:
  lwtQos: 0
  publickeypin: false
  clientID: OpenHABVM
  keepAlive: 60
  lwtMessage: OFFLINE
  secure: false
  lwtTopic: OpenHABVM/status
  certificatepin: true
  password: <nope>
  qos: 0
  reconnectTime: 60000
  port: 1883
  host: localhost
  lwtRetain: true
  enableDiscovery: true
  username: <nope>
channels:
  - id: openhabvm-updates
    channelTypeUID: mqtt:publishTrigger
    label: OpenHABVM Updates
    description: null
    configuration:
      stateTopic: openhabvm/out/+/state
      separator: "#"

Code: Alles auswählen

sudo apt install mosquitto mosquitto-clients

Code: Alles auswählen

cat /etc/openhab/automation/lib/python/configuration.py
# -*- coding: utf-8 -*-
LOG_PREFIX = "jsr223.jython"

admin_email = "<nope>"

openhabHost = "localhost"
openhabPort = "8080"

# The Channel ID of the MQTT Event Bus subscription channel
mqtt_eb_in_chan = "mqtt:broker:mosquitto:publishTrigger"

# The name to use for this instance of openHAB, forms the root of the MQTT topic
# hierarchy.
mqtt_eb_name = "OpenHABVM-Test"

# Thing ID for the MQTT broker Thing.
mqtt_eb_broker = "mqtt:broker:mosquitto"

# Optional flag, when True all Item commands and updates are published.
# Defaults to True.
mqtt_eb_puball = True

Code: Alles auswählen

mqtt_eb_in_chan = "mqtt:broker:mosquitto:publishTrigger"

Code: Alles auswählen

mqtt_eb_in_chan = "mqtt:broker:mosquitto:eventbus"

Code: Alles auswählen

mqtt_eb_puball = False

Code: Alles auswählen

Switch Foo [eb_command] // publishes only commands to the event bus
String Bar [eb_update] // publishes only updates to the event bus
Number Baz [eb_command,eb_update] // publishes both command and updates to the event bus

Code: Alles auswählen

Group gSmartHome "Smart-Home (Fakultaet IN)" <house>
Group gZimmer "Zimmer" <group> (gSmartHome)
Group gKonferenz "Konferenz" <corridor> (gZimmer)

Code: Alles auswählen

Group:String PubItems_CMD
Group:String PubItems_UPD

Code: Alles auswählen

/etc/openhab/automation/lib/python/community$ ls
'__init__$py.class'   __init__.py  'rules_utils$py.class'   rules_utils.py

/etc/openhab/automation/jsr223/python/community/mqtt_eb$ ls
mqtt_eb_pub.py  mqtt_eb_sub.py

Code: Alles auswählen

val eb_br = "mqtt:broker:mosquitto" // Thing ID of the broker connection
val eb_name = "remote"              // <client ID>

rule "Publish commands to the event bus"
when
    Member of PubItems_CMD received command // eb_cmd_gr
then
    val mqttActions = getActions("mqtt",eb_br) 
    mqttActions.publishMQTT(eb_name+"/out/"+triggeringItem.name+"/command",receivedCommand.toString)
end

rule "Publish updates to the event bus"
when
    Member of PubItems_UPD received update // eb_upd_gr
then
    val mqttActions = getActions("mqtt",eb_br)
    mqttActions.publishMQTT(eb_name+"/out/"+triggeringItem.name+"/state",triggeringItem.state.toString)
end    

Code: Alles auswählen

rule "Subscribe for commands and updates from the event bus"
when
    Channel "mqtt:broker:broker:remote-updates" triggered
then
    var topic = receivedEvent.toString.split("#").get(0)
    var state = receivedEvent.toString.split("#").get(1)
    val itemName = topic.split("/").get(2)
    val type = topic.split("/").get(3)

    if(type == "command") sendCommand(itemName, state)
    else postUpdate(itemName, state)
end

Code: Alles auswählen

rule "Eventbus Online"
when
    System started or
    Thing mqtt:broker:mosquitto changed to ONLINE
then
    logInfo("mqtt-eb", "Reporting eventbus as online")
    getActions("mqtt", "mqtt:broker:mosquitto").publishMQTT("openhab-remote/status", "ONLINE", true)
end

Code: Alles auswählen

mosquitto_sub -v -h <broker-ip> -p 1883 -t '#'
OpenHABVM/status OFFLINE

Code: Alles auswählen

sudo systemctl stop mosquitto.service
sudo rm /var/lib/mosquitto/mosquitto.db
sudo systemctl start mosquitto.service
mosquitto_sub -v -h <broker-ip> -p 1883 -t '#'

Code: Alles auswählen

    get /items
        Get all available items.

    put /items
        Adds a list of items to the registry or updates the existing items.

    delete /items/{itemName}/members/{memberItemName}
        Removes an existing member from a group item.

    put /items/{itemName}/members/{memberItemName}
        Adds a new member to a group item.

    delete /items/{itemname}
        Removes an item from the registry.

    get /items/{itemname}
        Gets a single item.

    post /items/{itemname}
        Sends a command to an item.

    put /items/{itemname}
        Adds a new item to the registry or updates the existing item.

    delete /items/{itemname}/metadata/{namespace}
        Removes metadata from an item.

    put /items/{itemname}/metadata/{namespace}
        Adds metadata to an item.

    get /items/{itemname}/state
        Gets the state of an item.

    put /items/{itemname}/state
        Updates the state of an item.

    delete /items/{itemname}/tags/{tag}
        Removes a tag from an item.

    put /items/{itemname}/tags/{tag}
        Adds a tag to an item.

Code: Alles auswählen

@log_traceback
def online(event):
    """Publishes ONLINE to mqtt_eb_name/status on System started."""

    init_logger.info("Reporting the event bus as ONLINE")
    from configuration import mqtt_eb_broker, mqtt_eb_name
    actions.get("mqtt", mqtt_eb_broker).publishMQTT("{}/status"
                                                    .format(mqtt_eb_name),
                                                    "ONLINE", True)

Code: Alles auswählen

13:30:10.164 [DEBUG] [re.automation.internal.RuleEngineImpl] - The trigger 'Time_cron_0_10_e1372dc0e09911eba3b60242f41ee9fd_e1821970e09911ebac930242f41ee9fd' of rule '74f10848-ff84-46de-9d7d-2fa440c07329' is triggered.
13:30:10.169 [INFO ] [jsr223.javascript                    ] - |Hello World JavaScript!|
13:30:10.168 [INFO ] [smarthome.event.RuleStatusInfoEvent  ] - 74f10848-ff84-46de-9d7d-2fa440c07329 updated: RUNNING
13:30:10.168 [INFO ] [jsr223.groovy                        ] - Hello World Groovy!
13:30:10.175 [DEBUG] [re.automation.internal.RuleEngineImpl] - The rule '768f5a9a-7c7e-4ae7-a878-d75f7ffaafc0' is executed.
13:30:10.165 [INFO ] [.Jython Hello World (cron decorators)] - Hello World Python!
13:30:10.167 [DEBUG] [re.automation.internal.RuleEngineImpl] - The trigger 'aTimerTrigger' of rule 'b1cde4b0-1b2e-4957-8247-261dffa0fbac' is triggered.
13:30:10.166 [DEBUG] [re.automation.internal.RuleEngineImpl] - The trigger '9ec06fc0-f5c3-4496-856a-cca4fca68ce8-HelloWorld-js' of rule '768f5a9a-7c7e-4ae7-a878-d75f7ffaafc0' is triggered.
13:30:10.175 [DEBUG] [re.automation.internal.RuleEngineImpl] - The rule 'b1cde4b0-1b2e-4957-8247-261dffa0fbac' is executed.

Code: Alles auswählen

sudo apt install mosquitto mosquitto-clients

Code: Alles auswählen

cp -r rules_utils/automation $OH_CONF
cp -r mqtt_eb/automation $OH_CONF

Code: Alles auswählen

sudo systemctl stop openhab2.service
cd ~
wget https://github.com/openhab-scripters/openhab-helper-libraries/archive/master.zip
unzip master.zip

sudo cp -R ~/openhab-helper-libraries/Core/* /etc/openhab2/
sudo chmod -R 777 /etc/openhab2/automation
sudo chown -R openhab:openhab /etc/openhab2/automation

Code: Alles auswählen

sudo mv /etc/openhab2/automation/lib/python/configuration.py.example /etc/openhab2/automation/lib/python/configuration.py
sudo mv /etc/openhab2/automation/lib/python/personal/__init__.py.example /etc/openhab2/automation/lib/python/personal/__init__.py

sudo nano /etc/default/openhab2
EXTRA_JAVA_OPTS="-Xms1024m -Xmx1536m -XX:+HeapDumpOnOutOfMemoryError -Xbootclasspath/a:/etc/openhab2/automation/jython/jython-standalone-2.7.0.jar -Dpython.home=/etc/openhab2/automation/jython -Dpython.path=/etc/openhab2/automation/lib/python"

sudo mkdir -p /etc/openhab2/automation/jython
wget https://repo1.maven.org/maven2/org/python/jython-standalone/2.7.0/jython-standalone-2.7.0.jar
sudo mv ~/jython-standalone-2.7.0.jar /etc/openhab2/automation/jython/jython-standalone-2.7.0.jar
sudo chmod -R 777 /etc/openhab2/automation/jython/
sudo chown -R openhab:openhab /etc/openhab2/automation/jython/

sudo cp -R ~/openhab-helper-libraries/Script\ Examples/Python/hello_world.py /etc/openhab2/automation/jsr223/python/personal/hello_world.py
sudo chmod +x /etc/openhab2/automation/jsr223/python/personal/hello_world.py
sudo chown -R openhab:openhab /etc/openhab2/automation/jsr223/python/personal/hello_world.py

Code: Alles auswählen

sudo mv /etc/openhab2/automation/lib/javascript/configuration.js.example /etc/openhab2/automation/lib/javascript/configuration.js

sudo cp -R ~/openhab-helper-libraries/Script\ Examples/JavaScript/HelloWorld.js /etc/openhab2/automation/jsr223/javascript/personal/HelloWorld.js
sudo chmod +x /etc/openhab2/automation/jsr223/javascript/personal/HelloWorld.js
sudo chown -R openhab:openhab /etc/openhab2/automation/jsr223/javascript/personal/HelloWorld.js

Code: Alles auswählen

wget https://dl.bintray.com/groovy/maven/apache-groovy-binary-2.4.12.zip

oder
wget https://archive.apache.org/dist/groovy/2.4.12/distribution/apache-groovy-binary-2.4.12.zip

unzip apache-groovy-binary-2.4.12.zip

sudo mv ~/groovy-2.4.12/lib/groovy*.jar /usr/share/openhab2/runtime/lib/ext
sudo chmod +x /usr/share/openhab2/runtime/lib/ext/*.jar
sudo chown -R openhab:openhab /usr/share/openhab2/runtime/lib/ext

sudo cp -R ~/openhab-helper-libraries/Script\ Examples/Groovy/HelloWorld.groovy /etc/openhab2/automation/jsr223/groovy/personal/HelloWorld.groovy
sudo chmod +x /etc/openhab2/automation/jsr223/groovy/personal/HelloWorld.groovy
sudo chown -R openhab:openhab /etc/openhab2/automation/jsr223/groovy/personal/HelloWorld.groovy

Code: Alles auswählen

sudo nano /etc/openhab2/automation/jsr223/python/personal/hello_world.py
sudo nano /etc/openhab2/automation/jsr223/javascript/personal/HelloWorld.js
sudo nano /etc/openhab2/automation/jsr223/groovy/personal/HelloWorld.groovy

Code: Alles auswählen

sudo rm -rf /var/lib/openhab2/cache/*
sudo rm -rf /var/lib/openhab2/tmp/*

sudo systemctl start openhab2.service
sudo systemctl restart openhab2.service

Code: Alles auswählen

log:set DEBUG org.openhab.core.automation
log:set DEBUG jsr223
log:tail

Code: Alles auswählen

cd ~
git clone https://github.com/rkoshak/openhab-rules-tools.git
cp -r ~/openhab-rules-tools/rules_utils/automation $OH_CONF
cp -r ~/openhab-rules-tools/mqtt_eb/automation $OH_CONF

sudo chmod -R 777 /etc/openhab2/automation
sudo chown -R openhab:openhab /etc/openhab2/automation

cat $OH_CONF/automation/lib/python/configuration.py.example | xclip

sudo nano $OH_CONF/automation/lib/python/configuration.py

Code: Alles auswählen

rule "Publish all"
when 
      Member of myGroupOfItems changed
then
   val actions = getActions("mqtt","mqtt:broker:myUnsecureBroker")
   actions.publishMQTT("allItems/"+triggeringItem.name,triggeringItem.state.toString)
end

Code: Alles auswählen

from core.rules import rule
from core.triggers import when

@rule("Publish all")
@when("Member of OutItems changed")
def MQTTPublishOut(event):
    output1 = event.itemName
    output2 = str(event.itemState)
    actions.get("mqtt","mqtt:broker:f79d2a84").publishMQTT("allItemsout/"+output1,output2)

@rule("Receive all")
@when("Channel mqtt:broker:f79d2a84:TriggerIn triggered")
def MQTTPublishIn(event):
    input1 = event.event
    input2 = input1.split("/")
    input3 = input2[1].split("#")
    events.sendCommand(input3[0], input3[1])