|
 |
3fb1ea |
From f2bf1d8a07ea810099b03469883cb7f485ab9ac1 Mon Sep 17 00:00:00 2001
|
|
|
3fb1ea |
From: Oyvind Albrigtsen <oalbrigt@redhat.com>
|
|
|
3fb1ea |
Date: Mon, 27 Jul 2020 10:09:43 +0200
|
|
|
3fb1ea |
Subject: [PATCH 1/2] azure-events: import URLError and encode postData when
|
|
|
3fb1ea |
necessary
|
|
|
3fb1ea |
|
|
|
3fb1ea |
---
|
|
|
3fb1ea |
heartbeat/azure-events.in | 6 ++++++
|
|
|
3fb1ea |
1 file changed, 6 insertions(+)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
diff --git a/heartbeat/azure-events.in b/heartbeat/azure-events.in
|
|
|
3fb1ea |
index d4a166d9f..a7f359468 100644
|
|
|
3fb1ea |
--- a/heartbeat/azure-events.in
|
|
|
3fb1ea |
+++ b/heartbeat/azure-events.in
|
|
|
3fb1ea |
@@ -13,8 +13,10 @@ import subprocess
|
|
|
3fb1ea |
import json
|
|
|
3fb1ea |
try:
|
|
|
3fb1ea |
import urllib2
|
|
|
3fb1ea |
+ from urllib2 import URLError
|
|
|
3fb1ea |
except ImportError:
|
|
|
3fb1ea |
import urllib.request as urllib2
|
|
|
3fb1ea |
+ from urllib.error import URLError
|
|
|
3fb1ea |
import socket
|
|
|
3fb1ea |
from collections import defaultdict
|
|
|
3fb1ea |
|
|
|
3fb1ea |
@@ -76,9 +78,13 @@ class azHelper:
|
|
|
3fb1ea |
Send a request to Azure's Azure Metadata Service API
|
|
|
3fb1ea |
"""
|
|
|
3fb1ea |
url = "%s/%s?api-version=%s" % (azHelper.metadata_host, endpoint, azHelper.api_version)
|
|
|
3fb1ea |
+ data = ""
|
|
|
3fb1ea |
ocf.logger.debug("_sendMetadataRequest: begin; endpoint = %s, postData = %s" % (endpoint, postData))
|
|
|
3fb1ea |
ocf.logger.debug("_sendMetadataRequest: url = %s" % url)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
+ if postData and type(postData) != bytes:
|
|
|
3fb1ea |
+ postData = postData.encode()
|
|
|
3fb1ea |
+
|
|
|
3fb1ea |
req = urllib2.Request(url, postData)
|
|
|
3fb1ea |
req.add_header("Metadata", "true")
|
|
|
3fb1ea |
req.add_header("User-Agent", USER_AGENT)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
From 1ab5d71bff95eb271f1e1bbc401961dc313219d9 Mon Sep 17 00:00:00 2001
|
|
|
3fb1ea |
From: Oyvind Albrigtsen <oalbrigt@redhat.com>
|
|
|
3fb1ea |
Date: Wed, 29 Jul 2020 21:25:43 +0200
|
|
|
3fb1ea |
Subject: [PATCH 2/2] azure-events: report error if jsondata not received
|
|
|
3fb1ea |
|
|
|
3fb1ea |
---
|
|
|
3fb1ea |
heartbeat/azure-events.in | 8 ++++++--
|
|
|
3fb1ea |
1 file changed, 6 insertions(+), 2 deletions(-)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
diff --git a/heartbeat/azure-events.in b/heartbeat/azure-events.in
|
|
|
3fb1ea |
index a7f359468..3a24d6358 100644
|
|
|
3fb1ea |
--- a/heartbeat/azure-events.in
|
|
|
3fb1ea |
+++ b/heartbeat/azure-events.in
|
|
|
3fb1ea |
@@ -117,8 +117,12 @@ class azHelper:
|
|
|
3fb1ea |
jsondata = azHelper._sendMetadataRequest(azHelper.instance_api)
|
|
|
3fb1ea |
ocf.logger.debug("getInstanceInfo: json = %s" % jsondata)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
- ocf.logger.debug("getInstanceInfo: finished, returning {}".format(jsondata["compute"]))
|
|
|
3fb1ea |
- return attrDict(jsondata["compute"])
|
|
|
3fb1ea |
+ if jsondata:
|
|
|
3fb1ea |
+ ocf.logger.debug("getInstanceInfo: finished, returning {}".format(jsondata["compute"]))
|
|
|
3fb1ea |
+ return attrDict(jsondata["compute"])
|
|
|
3fb1ea |
+ else:
|
|
|
3fb1ea |
+ ocf.ocf_exit_reason("getInstanceInfo: Unable to get instance info")
|
|
|
3fb1ea |
+ sys.exit(ocf.OCF_ERR_GENERIC)
|
|
|
3fb1ea |
|
|
|
3fb1ea |
@staticmethod
|
|
|
3fb1ea |
def pullScheduledEvents():
|