...
El componente FlowEngine de Plataforma ofrece un gran número de conectores para trabajar con redes sociales. Concretamente, incluye 2 dos componentes, : uno para “escuchar” lo que pasa en Twitter (por ejemplo recibiendo los tuits sobre un hashtag o hacer una búsqueda), y otro para publicar tuits:
...
En este post vamos a ver , verás cómo usar estos componentes para:
Escuchar lo que se dice en Twitter alrededor sobre de un tema.
Almacenar la información de ese un tuit en Plataforma.
Publicar un Tuit tuit con información recibida desde un servicio externo (OpenWeatherMaps).
Paso 1: Crear APP en Portal Developer en Twitter
Lo primero que debemos debes hacer es crearnos crearte una cuenta en Twitter. Una vez creada la cuenta iremos , ve al Portal del Developer de Twitter en https://developer.twitter.com/
...
Una vez dentro iremos , ve a la sección Apps y dentro seleccionaremos selecciona Create an App:
...
Nos Te pedirá que confirmemos confirmes que queremos quieres crear una cuenta de desarrollador, y completar que completes un conjunto de datos y tras completar nos . Tras completarlos, te llegará un mail para confirmar que queremos quieres crear una cuenta de desarrollador:
...
Tras esto, ya podemos puedes crear nuestra tu App y conseguir las Keys:
...
Como indican en la web, debemos debes guardar estas Keys, ya que tendremos tendrás que configurarlas en los componentes del FlowEngine:
...
Después de esto, podemos puedes probar el API REST de Twitter pulsando el botón Test an endpoint.
Como indicanse indica, podemos puedes probarlo con el comando:
curl -X GET -H "Authorization: Bearer <BEARER TOKEN>" "https://api.twitter.com/2/tweets/440322224407314432"
...
Tras probar esto, iremos ve al Dashboard. Dentro podemos , podrás configurar nuestra tu App.
...
Iremos Ve a la sección Keys and tokens y seleccionaremos selecciona Generate Access Token and Secret:
...
Que guardaremos también También debes guardarla, junto con el API Key y el API Key Secret:
...
IMPORTANTE: Hasta hace unos meses, esto era suficiente para terminar la configuración necesaria en Twitter; pero, con el cambio en la política de acceso a las APIs de Twitter, al registrarnos lo haremos , debes hacerlo con el nivel Essential que no permite el acceso al API 1.1 que es la que usa el componente Node-Red del FlowEngine.
...
Así que, para que funcione la comunicación con Twitter tendremos , tendrás que ir al Portal y solicitar el Apply for Elevated que ya nos te da permiso para acceder al API v1.1:
...
Nos Te pedirá una serie de información para habilitaros habilitarte el acceso a este nivel, como el uso que queremos hacer. Podemos Puedes indicar que queremos quieres probar a recoger tuits con Node-red.
...
Lo primero será tener un usuario en la instancia de Plataforma que quiera quieras usar. Para el ejemplo, usaremos usarás el entorno CloudLab de Plataforma (entorno gratuito con fines de experimentación). Así que iremos ve a https://lab.onesaitplatform.com/ y, si no tenemos tienes un usuario, lo crearemos créalo con el botón SIGN UP. Es importante que creemos Ten en cuenta que debes crear un usuario tipo DEVELOPER:
...
Con el usuario creado (recibiremos recibirás un mail para validar la creación), ya podemos logarnos puedes logarte en el Panel de Control de la Plataforma:
...
Una vez dentro, iremos ve a la opción de menú DEVELOPMENT>My DEVELOPMENT > My Flows:
...
Si es la primera vez que entramosentras, veremos verás que no tenemos creado un dominio del FlowEngine, así que pulsaremos pulsa el botón + para crearlo:
...
Le daremos Dale un nombre y pulsaremos pulsa Create:
...
Ahora ya veremos nuestro puedes ver tu dominio, que por defecto está parado, así que lo arrancaremos primero, arráncalo:
...
Una vez arrancado, podemos puedes acceder a él con el botón de View It:
...
Finalmente accederemos , accede a la Paleta del FlowEngine. Empezaremos Empieza por seleccionar que no queremos quieres crear un proyecto:
...
Podemos Puedes maximizar el área de trabajo con el botón de la esquina derecha:
...
Ahora buscaremos busca los componentes de Twitter con el buscador y arrastraremos arrastra el de Twitter In al lienzo:
...
El triángulo nos indica que debemos debes configurarlo. Para esto, pinchamos pincha dos veces sobre él para que aparezca la ventana de configuración.
...
En estaella, debemos debes configurar los las credenciales de Twitter que obtuvimos obtuviste en el paso 1:
...
Después, ya podemos puedes configurar lo que queremos quieres escuchar. Por ejemplo, podemos puedes elegir una tendencia. En el ejemplo, vamos vas a elegir #TheBatman en el día de su estreno en España:
...
Después, configuraremos configura el nodo debug para depurar por consola lo que llega:
...
Y para probarlo, simplemente hacemos haz un DEPLOY:
...
Y ya vemos verás en streaming los tuits sobre el tópico:
...
Para pararlo, podemos puedes eliminar el criterio de búsqueda.
...
En el FlowEngine, es muy fácil componer una lógica de negocio de modo que, ante ciertos eventos que sucedan (la llegada de un evento a una Entidad/Ontología por ejemplo), se componga y publique un mensaje que se publique.
En este sencillo ejemplo, simplemente publicaremos publicarás un texto. Para eso, usaremos usa el componente Inject configurado para inyectar un texto:
...
Tras esto haremos , haz el despliegue y pulsaremos pulsa el botón del componente Inject.
Tras esto podremos , podrás ver el mensaje:
...
Paso 3: Almacenar información de los tuits en una Entidad de Plataforma
Si volvemos vuelves al ejemplo en el que estábamos estabas escuchando lo que se decía sobre The Batman:
...
y ponemos pones un componente debug configurado para que saque todo el objeto msg:
...
entonces veremos verás en la pestaña debug una estructura como estaésta:
...
Para insertar estos datos en Plataforma, podemos crear una Entidad con estos atributos: topic, payload, lang, tweet, o usar la capacidad de Plataforma para crear una Entidad a partir de un JSON. Esta forma es mucho más sencilla cuando partimos de un JSON, como es el caso.
Desde la pestaña Debug, podemos puedes seleccionar uno de los objetos con el botón Copy value:
...
Si pegamos pegas el contenido en un editor, veremos verás algo como esto:
...
Como queremos quieres usar este JSON como ejemplo para crear nuestra Entidad, podemos puedes eliminar los atributos dentro del tweet, de modo que dejaremos quedará una estructura JSON como esta:
| Code Block |
|---|
{
"topic": "tweets/playlsit",
"payload": "robert pattinson as batman >>>>>>>",
"lang": "en",
"tweet": {},
"_msgid": "31a45aac.7fc556"
} |
Ahora vamos ve a la opción DEVELOPMENT/My Entities en el Control Panel y seleccionamos selecciona el botón + para crear una nueva Entidad:
...
Dentro nos encontramos con varias opciones. En este caso, nos te interesa la opción Create From File para usar el JSON como base para crear nuestra tu Entidad:
...
Al seleccionarla, podemos puedes copiar el JSON que hemos has dejado como plantilla y pulsar el botón Generate JSON-Schema:
...
Después pulsamos , pulsa Create y completamos completa los datos de nuestra tu Entidad:
...
Una vez creada, podemos puedes volver al FlowEngine para continuar con nuestro tu flujo.
Buscaremos Busca el componente onesaitplatform-insert y lo arrastraremosarrástralo. Después lo configuraremos , configúralo con nuestra tu Entidad:
...
Si lo conectamos conectas directamente a la salida de Twitter y debugeamos debugeas la salida, veremos verás que obtenemos obtienes un error:
...
Esto es porque la salida de los componentes en el FlowEngine es el msg.payload, que en nuestro tu caso es simplemente un texto:
...
mientras que el nodo Insert espera una estructura JSON completa como hemos has definido, ya que nos te interesa almacenar toda la info del tuit, incluido el usuario que tuitea.
...
donde el nodo Function convierte el msg a un payload en la salida:
...
Si ahora hacemos haces el DEPLOY, veremos verás que la inserción es correcta:
...
Para comprobar que de verdad se está almacenando esta información en una Entidad accederemos , accede a la herramienta Query Tool en TOOLS>Query Tool.
Dentro podemos Desde allí, puedes consultar los datos almacenados. Basta con que seleccionemos seleccione la Entidad y configuremos configures una consulta, o usemos uses la consulta por defecto:
...
Siguientes pasos
Una vez tenemos tienes los datos almacenados en Plataforma puedo , puedes, por ejemplo:
Explotar los datos con el Dashboard Engine por ejemplo mostrando tuits por zona, usuarios que más tuitean sobre un tema, …
Crear un Modelo con los Notebooks haciendo un análisis del sentimiento sobre los tuits, una distribución geográfica, …
Publicar un API REST con el API Manager con información agregada sobre un tema concreto.
...