Mysql Openstack Stored Procedures: различия между версиями

Материал из noname.com.ua
Перейти к навигацииПерейти к поиску
 
(не показано 17 промежуточных версий этого же участника)
Строка 1: Строка 1:
  +
[[Категория:Linux]]
−
<PRE>
  
   
  +
=Хранимые процедуры и отсылка оповещений об изменениях на HTTP=
−
openstack --os-identity-api-version 2 project create
  
   
  +
В MySQL есть такая возможность - использовать внешние пользовательские процедуры написанные на языке C <BR>
−
openstack --os-identity-api-version 2 project list
  
  +
Это дает возможность сделать триггер который при апдейте таблицы будет форматировать JSON и отправлять на удаленный сервер (или сервера)
−
+----------------------------------+----------+
  
  +
<BR>
−
| ID | Name |
  
  +
Идея на самом деле сомнительная потому что на время исполнения триггера таблица блокируется но как POC сойдет
−
+----------------------------------+----------+
  
−
| 3cd08ae190564da49ad9838039e566b4 | admin |
  
−
| 5e1d89c540764153970ffbe8ad3403d5 | services |
  
−
| ed43deaf0b944723af84732e481504dd | project1 |
  
−
+----------------------------------+----------+
  
   
  +
* http://www.mooreds.com/wordpress/archives/1497 Пример
−
openstack --os-identity-api-version 2 user create --project project1 --password user1 user1
  
−
+------------+----------------------------------+
  
−
| Field | Value |
  
−
+------------+----------------------------------+
  
−
| email | None |
  
−
| enabled | True |
  
−
| id | 7759b1b8b1f2489ba869f6ff4c4b26cd |
  
−
| name | user1 |
  
−
| project_id | ed43deaf0b944723af84732e481504dd |
  
−
| username | user1 |
  
−
+------------+----------------------------------+
  
−  
−
openstack --os-identity-api-version 2 role list
  
−
+----------------------------------+-----------------+
  
−
| ID | Name |
  
−
+----------------------------------+-----------------+
  
−
| 107d9c20c6fd44859a273015128f5020 | admin |
  
−
| 3518209f468a40618eea71eede882c4f | heat_stack_user |
  
−
| 9fe2ff9ee4384b1894a90878d3e92bab | _member_ |
  
−
| e556e1a095684c8ea2ab8ec10f87500b | SwiftOperator |
  
−
+----------------------------------+-----------------+
  
−
root@node-1:~# openstack --os-identity-api-version 2 role add --user 7759b1b8b1f2489ba869f6ff4c4b26cd --project project1 admin
  
−
+-----------+----------------------------------+
  
−
| Field | Value |
  
−
+-----------+----------------------------------+
  
−
| domain_id | None |
  
−
| id | 107d9c20c6fd44859a273015128f5020 |
  
−
| name | admin |
  
−
+-----------+----------------------------------+
  
−  
−  
−
</PRE>
  
−  
−  
−
* http://www.mooreds.com/wordpress/archives/1497
  
   
   
  +
==INSERT==
 
<PRE>
  
<PRE>
 
DELIMITER |
  
DELIMITER |
Строка 56: Строка 19:
 
FOR EACH ROW BEGIN
  
FOR EACH ROW BEGIN
 
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = NEW.uuid LIMIT 1);
  
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = NEW.uuid LIMIT 1);
  +
−
SET @tt_resu = (SELECT http_post(CONCAT('http://127.0.0.1:8081/', NEW.id), @tt_json));
  
  +
CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
  +
CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
  +
 
END |
  
END |
 
DELIMITER ;
  
DELIMITER ;
Строка 62: Строка 28:
   
   
  +
==BEFORE UPDATE==
−  
 
<PRE>
  
<PRE>
−  
−  
 
DELIMITER |
  
DELIMITER |
 
DROP TRIGGER IF EXISTS nova_instances_before_update;
  
DROP TRIGGER IF EXISTS nova_instances_before_update;
Строка 72: Строка 36:
 
FOR EACH ROW BEGIN
  
FOR EACH ROW BEGIN
 
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = OLD.uuid LIMIT 1);
  
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid = OLD.uuid LIMIT 1);
  +
−
SET @tt_resu = (SELECT http_post(CONCAT('http://127.0.0.1:8081/', OLD.id), @tt_json));
  
  +
CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
  +
CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
  +
 
END |
  
END |
 
DELIMITER ;
  
DELIMITER ;
−  
 
</PRE>
  
</PRE>
   
  +
==AFTER UPDATE==
 
<PRE>
  
<PRE>
−  
−  
 
DELIMITER |
  
DELIMITER |
 
DROP TRIGGER IF EXISTS nova_instances_after_update;
  
DROP TRIGGER IF EXISTS nova_instances_after_update;
Строка 87: Строка 52:
 
FOR EACH ROW BEGIN
  
FOR EACH ROW BEGIN
 
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid= OLD.uuid LIMIT 1);
  
SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid= OLD.uuid LIMIT 1);
−
INSERT into test1 SELECT created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted FROM instances;
  
−
SET @tt_resu = (SELECT http_post(CONCAT('http://127.0.0.1:8081/', OLD.uuid), @tt_json));
  
−
END |
  
−
DELIMITER ;
  
   
  +
CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
  +
CALL send_http_data('http://127.0.0.1:8081/', @tt_json);
   
  +
END |
  +
DELIMITER ;
 
</PRE>
  
</PRE>
   
−
<PRE>
  
   
  +
==Log==
  +
Табличка для записи в лог того что отправляется (debug)
   
  +
<PRE>
  +
DROP TABLE IF EXISTS httplog;
 
CREATE TABLE `httplog`
 
CREATE TABLE `httplog`
 
(
  
(
−
`request` varchar(32) DEFAULT NULL,
 +
`request` varchar(4096) DEFAULT NULL,
−
`response` varchar(10) DEFAULT NULL,
 +
`response` varchar(4096) DEFAULT NULL,
 
`seq` int(10) unsigned NOT NULL AUTO_INCREMENT,
  
`seq` int(10) unsigned NOT NULL AUTO_INCREMENT,
 
`local_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  
`local_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  +
`host` varchar(512) DEFAULT NULL,
 
PRIMARY KEY (`seq`)
  
PRIMARY KEY (`seq`)
 
);
  
);
   
  +
</PRE>
   
  +
==Отправка по HTTP==
  +
<PRE>
  +
  +
DROP PROCEDURE IF EXISTS send_http_data;
  +
  +
DELIMITER |
  +
CREATE PROCEDURE send_http_data(
  +
IN http_host varchar(512),
  +
IN http_data varchar(4096)
  +
) BEGIN
  +
  +
  +
  +
  +
SET @tt_resu = (SELECT http_post(http_host, http_data));
  +
INSERT INTO httplog(host, request,response) values(http_host, http_data, @tt_resu);
  +
  +
END |
  +
DELIMITER ;
  +
  +
  +
  +
  +
SET @tt_resu = (SELECT http_post(http_host, _data));
  +
INSERT INTO httplog(host, request,response) values(http_host, _data, @tt_resu);
 
</PRE>
  
</PRE>
   
  +
  +
  +
<PRE>
  +
DROP PROCEDURE IF EXISTS upload2;
  +
DELIMITER |
  +
  +
CREATE PROCEDURE upload2() BEGIN
  +
DECLARE done BOOLEAN DEFAULT FALSE;
  +
DECLARE json_data TEXT;
  +
DECLARE _uuid TEXT;
  +
DECLARE cur CURSOR FOR SELECT uuid from instances;
  +
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done := TRUE;
  +
  +
OPEN cur;
  +
  +
testLoop: LOOP
  +
FETCH cur INTO _uuid;
  +
IF done THEN
  +
LEAVE testLoop;
  +
END IF;
  +
  +
SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted) FROM instances WHERE uuid=_uuid LIMIT 1 INTO json_data;
  +
  +
CALL send_http_data('http://172.16.169.34:8080/', json_data);
  +
CALL send_http_data('http://127.0.0.1:8081/', json_data);
  +
  +
END LOOP testLoop;
  +
  +
CLOSE cur;
  +
END |
  +
DELIMITER ;
  +
</PRE>
   
 
=Ссылки=
  
=Ссылки=
 
* https://habrahabr.ru/post/37693/ - триггера
  
* https://habrahabr.ru/post/37693/ - триггера
  +
* http://www.mooreds.com/wordpress/archives/1497 Пример
  +
* https://github.com/y-ken/mysql-udf-http
  +
* http://dev.mysql.com/doc/refman/5.7/en/adding-udf.html

Текущая версия на 13:35, 21 сентября 2016


Хранимые процедуры и отсылка оповещений об изменениях на HTTP

В MySQL есть такая возможность - использовать внешние пользовательские процедуры написанные на языке C
Это дает возможность сделать триггер который при апдейте таблицы будет форматировать JSON и отправлять на удаленный сервер (или сервера)
Идея на самом деле сомнительная потому что на время исполнения триггера таблица блокируется но как POC сойдет


INSERT

DELIMITER |
DROP TRIGGER IF EXISTS nova_instances_insert;
CREATE TRIGGER  nova_instances_insert
AFTER INSERT ON instances
FOR EACH ROW BEGIN
    SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances  WHERE uuid = NEW.uuid LIMIT 1);

    CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
    CALL send_http_data('http://127.0.0.1:8081/', @tt_json);

END |
DELIMITER ;


BEFORE UPDATE

DELIMITER |
DROP TRIGGER IF EXISTS nova_instances_before_update;
CREATE TRIGGER nova_instances_before_update
BEFORE UPDATE ON instances
FOR EACH ROW BEGIN
    SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances  WHERE uuid = OLD.uuid LIMIT 1);

    CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
    CALL send_http_data('http://127.0.0.1:8081/', @tt_json);

END |
DELIMITER ;

AFTER UPDATE

DELIMITER |
DROP TRIGGER IF EXISTS nova_instances_after_update;
CREATE TRIGGER nova_instances_after_update
AFTER UPDATE ON instances
FOR EACH ROW BEGIN
    SET @tt_json = (SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted ) FROM instances WHERE uuid= OLD.uuid LIMIT 1);

    CALL send_http_data('http://172.16.169.34:8080/', @tt_json);
    CALL send_http_data('http://127.0.0.1:8081/', @tt_json);

END |
DELIMITER ;


Log

Табличка для записи в лог того что отправляется (debug) 

DROP TABLE IF EXISTS httplog;
CREATE TABLE `httplog` 
(
  `request` varchar(4096) DEFAULT NULL,
  `response` varchar(4096) DEFAULT NULL,
  `seq` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `local_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  `host` varchar(512) DEFAULT NULL,
  PRIMARY KEY (`seq`)
);

Отправка по HTTP


DROP PROCEDURE IF EXISTS send_http_data;

DELIMITER |
CREATE PROCEDURE send_http_data(
IN http_host varchar(512),
IN http_data varchar(4096)
) BEGIN




    SET @tt_resu = (SELECT http_post(http_host, http_data));
    INSERT INTO httplog(host, request,response) values(http_host, http_data, @tt_resu);

END |
DELIMITER ;




    SET @tt_resu = (SELECT http_post(http_host, _data));
    INSERT INTO httplog(host, request,response) values(http_host, _data, @tt_resu);



DROP PROCEDURE IF EXISTS upload2;
DELIMITER |

CREATE PROCEDURE upload2()  BEGIN
  DECLARE done BOOLEAN DEFAULT FALSE;
  DECLARE json_data TEXT;
  DECLARE _uuid TEXT;
  DECLARE cur CURSOR FOR SELECT uuid from instances;
  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done := TRUE;

  OPEN cur;

  testLoop: LOOP
    FETCH cur INTO _uuid;
    IF done THEN
      LEAVE testLoop;
    END IF;

    SELECT json_object(created_at,updated_at,id,user_id,project_id,image_ref,hostname,reservation_id,uuid,deleted) FROM instances WHERE uuid=_uuid LIMIT 1  INTO json_data;

    CALL send_http_data('http://172.16.169.34:8080/', json_data);
    CALL send_http_data('http://127.0.0.1:8081/', json_data);

  END LOOP testLoop;

  CLOSE cur;
END |
DELIMITER ;

Ссылки

Источник — https://noname.com.ua/mediawiki/index.php?title=Mysql_Openstack_Stored_Procedures&oldid=7943