add AnomalyDetector sample (#40)

* init

* add anomaly detector sample

Author: moreOver0

requirements.txt

@@ -15,3 +15,5 @@ azure-cognitiveservices-vision-computervision>=0.3.0  # sample won't work with p
 azure-cognitiveservices-vision-contentmoderator>=1.0.0  # sample won't work with previous versions
 azure-cognitiveservices-vision-customvision>=0.4.0  # sample won't work with previous versions
 azure-cognitiveservices-vision-face
+azure-cognitiveservices-anomalydetector>=0.2.0 #  sample won't work with previous versions
+pandas

samples/anomaly_detector_samples.py

@@ -0,0 +1,70 @@
+from azure.cognitiveservices.anomalydetector import AnomalyDetectorClient
+from azure.cognitiveservices.anomalydetector.models import Request, Point, Granularity, \
+    APIErrorException
+from datetime import datetime, timezone
+from msrest.authentication import CognitiveServicesCredentials
+import pandas as pd
+import os
+
+SUBSCRIPTION_KEY_ENV_NAME = "ANOMALYDETECTOR_SUBSCRIPTION_KEY"
+ANOMALYDETECTOR_LOCATION = os.environ.get("ANOMALYDETECTOR_LOCATION", "westcentralus")
+
+CSV_FOLDER = os.path.join(os.path.dirname(os.path.realpath(__file__)), "csv_files")
+
+def get_series_from_file(path):
+    df = pd.read_csv(path, header=None, encoding="utf-8", parse_dates=[0])
+    series = []
+    for index, row in df.iterrows():
+        series.append(Point(timestamp=row[0], value=row[1]))
+    return series
+
+def get_request():
+    series = get_series_from_file(os.path.join(CSV_FOLDER, "anomaly_detector_daily_series.csv"))
+    return Request(series=series, granularity=Granularity.daily)
+
+def entire_detect(subscription_key):
+    print("Sample of detecting anomalies in the entire series.")
+
+    endpoint = "https://{}.api.cognitive.microsoft.com".format(ANOMALYDETECTOR_LOCATION)
+    try:
+        client = AnomalyDetectorClient(endpoint, CognitiveServicesCredentials(subscription_key))
+        request = get_request()
+        response = client.entire_detect(request)
+        if True in response.is_anomaly:
+            print("Anomaly was detected from the series at index:")
+            for i in range(len(request.series)):
+                if response.is_anomaly[i]:
+                    print(i)
+        else:
+            print("There is no anomaly detected from the series.")
+    except Exception as e:
+        if isinstance(e, APIErrorException):
+            print("Error code: {}".format(e.error.code))
+            print("Error message: {}".format(e.error.message))
+        else:
+            print(e)
+
+def last_detect(subscription_key):
+    print("Sample of detecting whether the latest point in series is anomaly.")
+
+    endpoint = "https://{}.api.cognitive.microsoft.com".format(ANOMALYDETECTOR_LOCATION)
+    try:
+        client = AnomalyDetectorClient(endpoint, CognitiveServicesCredentials(subscription_key))
+        request = get_request()
+        response = client.last_detect(request)
+        if response.is_anomaly:
+            print("The latest point is detected as anomaly.")
+        else:
+            print("The latest point is not detected as anomaly.")
+    except Exception as e:
+        if isinstance(e, APIErrorException):
+            print("Error code: {}".format(e.error.code))
+            print("Error message: {}".format(e.error.message))
+        else:
+            print(e)
+
+if __name__ == "__main__":
+    import sys, os.path
+    sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
+    from tools import execute_samples
+    execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)

samples/csv_files/anomaly_detector_daily_series.csv

@@ -0,0 +1,47 @@
+2018-03-01T00:00:00Z,32858923
+2018-03-02T00:00:00Z,29615278
+2018-03-03T00:00:00Z,22839355
+2018-03-04T00:00:00Z,25948736
+2018-03-05T00:00:00Z,34139159
+2018-03-06T00:00:00Z,33843985
+2018-03-07T00:00:00Z,33637661
+2018-03-08T00:00:00Z,32627350
+2018-03-09T00:00:00Z,29881076
+2018-03-10T00:00:00Z,22681575
+2018-03-11T00:00:00Z,24629393
+2018-03-12T00:00:00Z,34010679
+2018-03-13T00:00:00Z,33893888
+2018-03-14T00:00:00Z,33760076
+2018-03-15T00:00:00Z,33093515
+2018-03-16T00:00:00Z,29945555
+2018-03-17T00:00:00Z,22676212
+2018-03-18T00:00:00Z,25262514
+2018-03-19T00:00:00Z,33631649
+2018-03-20T00:00:00Z,34468310
+2018-03-21T00:00:00Z,34212281
+2018-03-22T00:00:00Z,38144434
+2018-03-23T00:00:00Z,34662949
+2018-03-24T00:00:00Z,24623684
+2018-03-25T00:00:00Z,26530491
+2018-03-26T00:00:00Z,35445003
+2018-03-27T00:00:00Z,34250789
+2018-03-28T00:00:00Z,33423012
+2018-03-29T00:00:00Z,30744783
+2018-03-30T00:00:00Z,25825128
+2018-03-31T00:00:00Z,21244209
+2018-04-01T00:00:00Z,22576956
+2018-04-02T00:00:00Z,31957221
+2018-04-03T00:00:00Z,33841228
+2018-04-04T00:00:00Z,33554483
+2018-04-05T00:00:00Z,32383350
+2018-04-06T00:00:00Z,29494850
+2018-04-07T00:00:00Z,22815534
+2018-04-08T00:00:00Z,25557267
+2018-04-09T00:00:00Z,34858252
+2018-04-10T00:00:00Z,34750597
+2018-04-11T00:00:00Z,34717956
+2018-04-12T00:00:00Z,34132534
+2018-04-13T00:00:00Z,30762236
+2018-04-14T00:00:00Z,22504059
+2018-04-15T00:00:00Z,26149060
+2018-04-16T00:00:00Z,35250105