Routerboard CRS125-24G-1S-2HnD-IN (Mikrotik) Cloud Switch
I bought this product a few weeks ago and finally I can enjoy it at home. With this product you have a firewall, gateway, switch and wireless box with:
- 25x Gigabit Ethernet ports
- 1x Fiber channel
- 3G, 4G or any optional USB modem
- With RouterOS inside you can manage: gateway, firewall, VPN and ad-hoc switching and routing configurations
- 1000mW high power 2.4GHz 11n wireless AP
The official product page is here where you can find brochure in PDF and other useful information.
If you are looking for a powerful product for your SOHO network this is the solution as I like to say ‘this is one of the best communications servers’. It will be very difficult to find some feature or functionality that you can not get from this product. The product is robust and stable with the flexibility of RouterOS.
Conferència: La revolució dels mini-PC: Raspberry PI, Arduino i més
Ahir al vespre vaig fer una conferència a la FIB (Facultat d’Informàtica de Barcelona) dins de la UPC (Universitat Politècnica de Catalunya). En aquesta xerra vaig estar explicant què és i en que es diferència Arduino i Raspberry PI. A més de presentar tot un conjunt de solucions alternatives i experiències en el tema.
En aquest enllaç podeu trobar les transparències de: La revolució dels mini-PC: Raspberry PI, Arduino i més. i el video el teniu disponible al servidor de la FIB.
Ara també teniu disponible el video a youtube:
i podeu veure les transparències des d’aquest mateix post:
Espero els vostres feedbacks als comentaris, desitjo que ús sigui útil.
Qué es para mi la felicidad?
Entrar en estos conceptos es muy difícil y cada uno puede tener su propia forma de describirlo. Pero en mi caso, me quiero atrever a definir lo que es para mi la felicidad; eso no quiere decir que vaya mañana y lo cambie. Así pues lo más importante que quiero aportar es que para mi la felicidad no es un objetivo sinó un estado, una decisión que un día tome: voy a pasar mi vida en un estado de felicidad. La felicidad nace en mi y la siento dentro de mi. Obviamente hay mil agentes externos que hacen presión para afectar a esa deicisión y ahí es donde entra el trabajo de cultivar la paz interior y el equilibrio entre las cuatro partes que según mi forma de entender la vida forman a todos las personas.
Cuando planteo esto a otra persona a menudo insiste una y otra vez con entender como gestiono la influencia de mil y un elementos externos sobre mi felicidad. No soy ningún gurú, maestro budista, ni siquiera un filósofo. Sólo soy alguien que se atreve a seguir sus creencias día tras dia. Una vez tomada la decisión de vivir en un estado de felicidad lo que hago para que esta no me abanadone es seguir mi vida integrando los siquientes elementos.
És fundamental cultivar la autoestima, hablarse con amor a uno mismo. Yo tengo la tendencia a ser muy perfeccionista y eso desencadena en un lenguaje muy duro y a menudo autodestructivo sobre mi mismo. Pues bien, en mi trabajo para corregir esto de momento ya he conseguido darme cuenta casi el 100% de las veces cuando lo hago y tomar medidas. Lo primero es tomar prespectiva sobre los temas que han provocado ese mensaje tan agresivo sobre mi mismo. Después de este ejercicio me fuerzo a empezar a hablarme con amor y a saber valorar cuales son mis fortalezas, para poder centrarme en mejorar las debilidades y seguir potenciando las cualidades que tengo.
Esta descripción me lleva a hablar de fluir con las emociones, es muy importante no engancharse en los estados de ánimo. Cosa que sabemos hacer todos. Para trabajar este aspecto trabajo mucho la observación de los niños. Observar la capacidad de reir y llorar con todo el sentimiento en segundos de diferencia no esta al habasto de todos. Cuando eres capaz de sentir las emociones con una profundidad extrema pero sin estar enganchado a ellas puedes sumergirte en cada uno de los instantes de la vida sin miedo.
Una de las mejores cosas que tiene la vida es la relación con las otras personas. No puedo hablar por el resto de las personas pero si puedo decir que cuando me pasa algo bueno no puedo evitar tener la necesidad de compartirlo. Para mi la empatia empieza en este punto. Es decir para la mi la empatia es parte de nuestro ser social. Cuando empiezas a relacionarte en los demas y a ver lo importante que es su presencia para nosotros mismos empatizar con ellos es parte del proceso de la relación. Saber fluir a la misma frecuencia que nos estan transmitiendo hace más fácil el disfrute de cada instante. Es evidente que no todos los momentos son alegres, pero también lo es que cuando reflexionas sobre esos momentos te das cuenta de hasta que punto eran necesarios.
El siguiente punto en este trabajo se mezcla con el que le sucede. Es decir no sabría decir con total convicción si primero va el perdón o después la aceptación. Hay instantes en los que estoy convencido de que primero tengo que perdonarme a mi mismo para poder aceptar ciertas partes de mi pero también me ha sucedido que he aceptado alguna acción sin haberla perdonado y después me ha sido muy sencillo perdonarme. Eso me lleva a pensar que quizá ya me había perdonado antes y no me había dado cuenta. En cualquier paso para poder vivir con plenitud cada instante debemos permitirnoslo y a menudo no somos capaces de hacer tal cosa. Cuantas veces hemos estado en un sitio haciendo algo y al mismo tiempo tenemos la cabeza en otra parte. ¿En ese momento nos estamos permitiendo vivir ese instante?
Muchas veces me preguntan como puedes leer un libro sabiendo que tienes otros tantos pendientes. ¿Como sabes que no te has equivocado priorizando ese libro? pues la verdad, no lo sé. Pero tampoco no me importante acepto mi elección y disfruto de ella y si en algún momento me doy cuenta que el resultado que he obtenido no era el que esperaba me perdono. Porqué se que en ese momento lo que hice era lo mejor que podía hacer. Esto me lleva a hablar de la intención positiva, cuando estuié PNL una de las cosas más interioricé es el hecho de buscar donde esta la intención positiva en cada una de las acciones que hago o que se realizan a mi alrededor. Cuando estas totalmente convencido de que detrás de cualquier acción hay una intención positiva, que no siempre tienes porqué compartir, aceptar la acción y perdonar a través de la compasión se hace un acto natural.
Como en cualquier fórmula siempre hay un elemento más escaso que el resto, en mi caso es la asertividad este modelo de conducta no es sencillo de practicar en todos los instantes. Pero es un desafio que acepto y disfruto a diario. La asertividad es una linia de conducta muy fina y sutil situada entre dos extremos muy claros por un lado la agresividad y por el otro la pasividad. Saber defender tus ideas, sentimientos o derechos sin la intención de herir o perjudicar desde la autoconfianza usando una expresión consciente, congruente, clara, directa y equilibrada. Diría que todo esto es un reto difícil de sostener en el tiempo y por eso me emociona y me motiva trabajar para interiorizarlo.
Todos estos puntos cuando los convertimos en tema de una charla con otras personas, siempre me acaban diciendo que no entienden como puedo hablar de todos estos temas y dedicarme a un mundo aparentemente tan frio como el de la tecnología. Pues bien, para mi esto esta relacionado con los objetivos. Vivir el momento y desde en una opción de felicidad es una tarea que para mi sólo tiene sentido en el marco de los objetivos. Cuando hablo de objetivos los aplico a cada una de las areas de mi vida, no sólo a la parte personal y profesional. Sinó a todas. Tener claro cuales son los objetivos y los meta-objetivos de cada uno de los proyectos que desarrollo en las areas de mi vida me ayuda a reforzar la pasión, la motiviació, el compromiso y con el corazón en la mano os puedo decir que sentir la felicidad en cada instante se hace algo natural.
Para cerrar esta reflexión podríamos resumir que vivir los momentos desde una opción de felicidad es la suma de:
Felicidad = autoestima + fluir con las emociones + empatizar + perdonarte + aceptación + intención positiva + asertvidad + objetivos
Recording linux desktop and audio
I have two full-HD displays as a desktop and I want to record the second one of them while I record mic too. The output format of the record has to be MKV with h264 as video codec and AAC as audio codec.
After some tests with VLC and FFMPEG finally I get the solution with this command:
ffmpeg -f alsa -ac 2 -i default -f x11grab -r 15 -s 1920x1080+0+0 -i :0.0+1920,0 \ -acodec pcm_s16le -vcodec libx264 -preset ultrafast -threads 0 -y Test.mkv
when I finish recording the clip I have to convert the audio channel because if I try to convert the audio format while I’m recording the audio channel I have delays or sync problems with video channel.
ffmpeg -i Test.mkv -map 0:0 -map 0:1 \ -c:v copy \ -c:a:1 libfdk_aac -profile:a aac_he_v2 -b:a:1 96k \ output.mkv
Hello World using ‘kombu’ library and python
Some times schemas and snippets don’t need large descriptions. If you think this is not enough in this case tell me and I’m going to add explanations.
Using a python library called kombu as an abstraction to talk with AMQP broker we are going to develop different message routes setting each type of Exchange. As a backend I used RabbitMQ with default configuration.
AMQP schema using an exchange of type direct
Queue definition:
from kombu import Exchange, Queue task_exchange = Exchange("msgs", type="direct") queue_msg_1 = Queue("messages_1", task_exchange, routing_key = 'message_1') queue_msg_2 = Queue("messages_2", task_exchange, routing_key = 'message_2')
The producer:
from __future__ import with_statement from queues import task_exchange from kombu.common import maybe_declare from kombu.pools import producers if __name__ == "__main__": from kombu import BrokerConnection connection = BrokerConnection("amqp://guest:guest@localhost:5672//") with producers[connection].acquire(block=True) as producer: maybe_declare(task_exchange, producer.channel) payload = {"type": "handshake", "content": "hello #1"} producer.publish(payload, exchange = 'msgs', serializer="pickle", routing_key = 'message_1') payload = {"type": "handshake", "content": "hello #2"} producer.publish(payload, exchange = 'msgs', serializer="pickle", routing_key = 'message_2')
One consumer:
from queues import queue_msg_1 from kombu.mixins import ConsumerMixin class C(ConsumerMixin): def __init__(self, connection): self.connection = connection return def get_consumers(self, Consumer, channel): return [Consumer( queue_msg_1, callbacks = [ self.on_message ])] def on_message(self, body, message): print ("RECEIVED MSG - body: %r" % (body,)) print ("RECEIVED MSG - message: %r" % (message,)) message.ack() return if __name__ == "__main__": from kombu import BrokerConnection from kombu.utils.debug import setup_logging setup_logging(loglevel="DEBUG") with BrokerConnection("amqp://guest:guest@localhost:5672//") as connection: try: C(connection).run() except KeyboardInterrupt: print("bye bye")
AMQP schema using an exchange of type fanout
Queue definition:
from kombu import Exchange, Queue task_exchange = Exchange("ce", type="fanout") queue_events_db = Queue("events.db", task_exchange) queue_events_notify = Queue("events.notify", task_exchange)
The producer:
from __future__ import with_statement from queues import task_exchange from kombu.common import maybe_declare from kombu.pools import producers if __name__ == "__main__": from kombu import BrokerConnection connection = BrokerConnection("amqp://guest:guest@localhost:5672//") with producers[connection].acquire(block=True) as producer: maybe_declare(task_exchange, producer.channel) payload = {"operation": "create", "content": "the object"} producer.publish(payload, exchange = 'ce', serializer="pickle", routing_key = 'user.write') payload = {"operation": "update", "content": "updated fields", "id": "id of the object"} producer.publish(payload, exchange = 'ce', serializer="pickle", routing_key = 'user.write')
One consumer:
from queues import queue_events_db from kombu.mixins import ConsumerMixin class C(ConsumerMixin): def __init__(self, connection): self.connection = connection return def get_consumers(self, Consumer, channel): return [Consumer( queue_events_db, callbacks = [self.on_message])] def on_message(self, body, message): print ("save_db: RECEIVED MSG - body: %r" % (body,)) print ("save_db: RECEIVED MSG - message: %r" % (message,)) message.ack() return if __name__ == "__main__": from kombu import BrokerConnection from kombu.utils.debug import setup_logging setup_logging(loglevel="DEBUG") with BrokerConnection("amqp://guest:guest@localhost:5672//") as connection: try: C(connection).run() except KeyboardInterrupt: print("bye bye")
AMQP schema using an exchange of type topic
Queue definition:
from kombu import Exchange, Queue task_exchange = Exchange("user", type="topic") queue_user_write = Queue("user.write", task_exchange, routing_key = 'user.write') queue_user_read = Queue("user.read", task_exchange, routing_key = 'user.read') queue_notify = Queue("notify", task_exchange, routing_key = 'user.#')
The producer:
from __future__ import with_statement from queues import task_exchange from kombu.common import maybe_declare from kombu.pools import producers if __name__ == "__main__": from kombu import BrokerConnection connection = BrokerConnection("amqp://guest:guest@localhost:5672//") with producers[connection].acquire(block=True) as producer: maybe_declare(task_exchange, producer.channel) payload = {"operation": "create", "content": "the object"} producer.publish(payload, exchange = 'user', serializer="pickle", routing_key = 'user.write') payload = {"operation": "update", "content": "updated fields", "id": "id of the object"} producer.publish(payload, exchange = 'user', serializer="pickle", routing_key = 'user.write') payload = {"operation": "delete", "id": "id of the object"} producer.publish(payload, exchange = 'user', serializer="pickle", routing_key = 'user.write') payload = {"operation": "read", "id": "id of the object"} producer.publish(payload, exchange = 'user', serializer="pickle", routing_key = 'user.read')
One consumer:
from queues import queue_events_db from kombu.mixins import ConsumerMixin class C(ConsumerMixin): def __init__(self, connection): self.connection = connection return def get_consumers(self, Consumer, channel): return [Consumer( queue_events_db, callbacks = [self.on_message])] def on_message(self, body, message): print ("save_db: RECEIVED MSG - body: %r" % (body,)) print ("save_db: RECEIVED MSG - message: %r" % (message,)) message.ack() return if __name__ == "__main__": from kombu import BrokerConnection from kombu.utils.debug import setup_logging setup_logging(loglevel="DEBUG") with BrokerConnection("amqp://guest:guest@localhost:5672//") as connection: try: C(connection).run() except KeyboardInterrupt: print("bye bye")
Simple queues
Kombu implements SimpleQueue and SimpleBuffer as simple solution for queues with exchange of type ‘direct’, with the same exchange name, routing key and queue name.
Pusher:
from kombu import BrokerConnection connection = BrokerConnection("amqp://guest:guest@localhost:5672//") queue = connection.SimpleQueue("logs") payload = { "severity":"info", "message":"this is just a log", "ts":"2013/09/30T15:10:23" } queue.put(payload, serializer='pickle') queue.close()
Getter:
from kombu import BrokerConnection from Queue import Empty connection = BrokerConnection("amqp://guest:guest@localhost:5672//") queue = connection.SimpleQueue("logs") while 1: try: message = queue.get(block=True, timeout=1) print message.payload message.ack() except Empty: pass except KeyboardInterrupt: break print message queue.close()
The files
Download all example files: kombu-tests.tar.gz
Server send push notifications to client browser without polling
Nowadays last version of browsers support websockets and it’s a good a idea to use them to connect to server a permanent channel and receive push notifications from server. In this case I’m going to use Mosquitto (MQTT) server behind lighttpd with mod_websocket as notifications server. Mosquitto is a lightweight MQTT server programmed in C and very easy to set up. The best advantage to use MQTT is the possibility to create publish/subscriber queues and it’s very useful when you want to have more than one notification channel. As is usual in pub/sub services we can subscribe the client to a well-defined topic or we can use a pattern to subscribe to more than one topic. If you’re not familiarized with MQTT now it’s the best moment to read a little bit about because that interesting protocol. It’s not the purpose of this post to explain MQTT basics.
A few weeks ago I set up the next architecture just for testing that idea:
The browser
Now it’s time to explain this proof of concept. HTML page will contain a simple Javascript code which calls mqttws31.js library from Paho. This Javascript code will connect to the server using secure websockets. It doesn’t have any other security measure for a while may be in next posts I’ll explain some interesting ideas to authenticate the websocket. At the end of the post you can download all source code and configuration files. But now it’s time to understand the most important parts of the client code.
client = new Messaging.Client("ns.example.tld", 443, "unique_client_id"); client.onConnectionLost = onConnectionLost; client.onMessageArrived = onMessageArrived; client.connect({onSuccess:onConnect, onFailure:onFailure, useSSL:true});
Last part is very simple, the client connects to the server and links some callbacks to defined functions. Pay attention to ‘useSSL’ connect option is used to force SSL connection with the server.
There are two specially interesting functions linked to callbacks, the first one is:
function onConnect() { client.subscribe("/news/+/sport", {qos:1,onSuccess:onSubscribe,onFailure:onSubscribeFailure}); }
As you can imagine this callback will be called when the connections is established, when it happens the client subscribes to all channels called ‘/news/+/sports’, for example, ‘/news/europe/sports/’ or ‘/news/usa/sports/’, etc. We can also use, something like ‘/news/#’ and it will say we want to subscribe to all channels which starts with ‘/news/’. If only want to subscribe to one channel put the full name of the channel on that parameter. Next parameter are dictionary with quality of service which is going to use and links two more callbacks.
The second interesting function to understand is:
function onMessageArrived(message) { console.log("onMessageArrived:"+message.payloadString); };
It’s called when new message is received from the server and in this example, the message is printed in console with log method.
The server
I used an Ubuntu 12.04 server with next extra repositories:
# lighttpd + mod_webserver deb http://ppa.launchpad.net/roger.light/ppa/ubuntu precise main deb-src http://ppa.launchpad.net/roger.light/ppa/ubuntu precise main # mosquitto deb http://ppa.launchpad.net/mosquitto-dev/mosquitto-ppa/ubuntu precise main deb-src http://ppa.launchpad.net/mosquitto-dev/mosquitto-ppa/ubuntu precise main
With these new repositories you can install required packages:
apt-get install lighttpd lighttpd-mod-websocket mosquitto mosquitto-clientsAfter installation it’s very easy to run mosquitto in test mode, use a console for that and write the command: mosquitto, we have to see something like this:
# mosquitto 1379873664: mosquitto version 1.2.1 (build date 2013-09-19 22:18:02+0000) starting 1379873664: Using default config. 1379873664: Opening ipv4 listen socket on port 1883. 1379873664: Opening ipv6 listen socket on port 1883.
The configuration file for lighttpd in testing is:
server.modules = ( "mod_websocket", ) websocket.server = ( "/mqtt" => ( "host" => "127.0.0.1", "port" => "1883", "type" => "bin", "subproto" => "mqttv3.1" ), ) server.document-root = "/var/www" server.upload-dirs = ( "/var/cache/lighttpd/uploads" ) server.errorlog = "/var/log/lighttpd/error.log" server.pid-file = "/var/run/lighttpd.pid" server.username = "www-data" server.groupname = "www-data" server.port = 80 $SERVER["socket"] == ":443" { ssl.engine = "enable" ssl.pemfile = "/etc/lighttpd/certs/sample-certificate.pem" server.name = "ns.example.tld" }
Remember to change ‘ssl.pemfile’ for your real certificate file and ‘server.name’ for your real server name. Then restart the lighttpd and validate SSL configuration using something like:
openssl s_client -host ns.example.tld -port 443You have to see SSL negotiation and then you can try to send HTTP commands, for example: “GET / HTTP/1.0” or something like this. Now the server is ready.
The Test
Now you have to load the HTML test page in your browser and validate how the connections is getting the server and then how the mosquitto console says how it receives the connection. Of course, you can modify the Javascript code to print more log information and follow how the client is connected to MQTT server and how it is subscribed to the topic pattern.
If you want to publish something in MQTT server we could use the CLI, with a command mosquitto_pub:
mosquitto_pub -h ns.example.tld -t '/news/europe/sport' -m 'this is the message about european sports'Take a look in your browser Javascript consle you have to see how the client prints the message on it. If it fails, review the steps and debug each one to solve the problem. If you need help leave me a message. Of course, you can use many different ways to publish messages, for example, you could use python code to publish messages in MQTT server. In the same way you could subscribe not only browsers to topics, for example, you could subscribe a python code:
import mosquitto def on_connect(mosq, obj, rc): print("rc: "+str(rc)) def on_message(mosq, obj, msg): print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload)) def on_publish(mosq, obj, mid): print("mid: "+str(mid)) def on_subscribe(mosq, obj, mid, granted_qos): print("Subscribed: "+str(mid)+" "+str(granted_qos)) def on_log(mosq, obj, level, string): print(string) mqttc = mosquitto.Mosquitto("the_client_id") mqttc.on_message = on_message mqttc.on_connect = on_connect mqttc.on_publish = on_publish mqttc.on_subscribe = on_subscribe mqttc.connect("ns.example.tld", 1883, 60) mqttc.subscribe("/news/+/sport", 0) rc = 0 while rc == 0: rc = mqttc.loop()
Pay attention to server port, it isn’t the ‘https’ port (443/tcp) because now the code is using a real MQTT client. The websocket gateway isn’t needed.
The files
- mqtt.tar.gz – inside this tar.gz you can find all referenced files