Add IN Operator for DE Retrieve Rows via REST API

Sebastien.Dangelo · Sebastien.Dangelo · commit 66ec7ba57c54 · 2020-04-16T05:24:56.000-05:00
diff --git a/FuelSDKWrapper.py b/FuelSDKWrapper.py
@@ -257,6 +257,10 @@ def search_filter(property_name, operator, value):
 
 
 def simple_filter(property_name, operator, value):
+    if operator == Operator.IN and not isinstance(value, list) and not isinstance(value, tuple)\
+            and not isinstance(value, set) and not isinstance(value, frozenset):
+        raise ET_API.ETApiError("Search filter with IN operator needs a list as value parameter.")
+
     value_type = 'Value'
     if isinstance(value, date) or isinstance(value, datetime):
         value_type = 'DateValue'
@@ -295,6 +299,9 @@ def search_filter_for_rest_call(search_filter):
             value = search_filter.get('Value', search_filter.get('DateValue'))
             if operator == 'like':
                 value = value.replace('%', '%25')
+
+            if operator == 'in':
+                return "{}%20{}%20('{}')".format(prop, operator, "','".join(value))
             return "{}%20{}%20'{}'".format(prop, operator, value)
 
 
@@ -308,7 +315,8 @@ def operator_for_rest_call(operator):
         'lessThanOrEqual': 'lte',
         'like': 'like',
         'isNull': 'IS%20NULL',
-        'isNotNull': 'IS%20NOT%20NULL'
+        'isNotNull': 'IS%20NOT%20NULL',
+        'IN': 'in'
     }
     return operators[operator]
 
diff --git a/README.md b/README.md
@@ -180,6 +180,12 @@ items, items_count = api.get_data_extension_rows_rest(
     max_rows=300
 )
 
+items, items_count = api.get_data_extension_rows_rest(
+    customer_key="DE_CUSTOMER_KEY",
+    search_filter=simple_filter("first_name", Operator.IN, ["Jane", "John"]),
+    top=100
+)
+
 # Get Email Rendered Preview
 res = api.get_objects(
     ObjectType.EMAIL, 
diff --git a/__init__.py b/__init__.py
@@ -1,4 +1,4 @@
 __title__ = 'FuelSDKWrapper'
-__version__ = '1.2.8'
+__version__ = '1.2.9'
 __author__ = 'Seb Angel'
 __license__ = 'MIT'
diff --git a/setup.py b/setup.py
@@ -4,7 +4,7 @@
     readme = f.read()
 
 setup(
-    version='1.2.8',
+    version='1.2.9',
     name='FuelSDKWrapper',
     description='Simplify and enhance the FuelSDK for Salesforce Marketing Cloud (ExactTarget)',
     long_description=readme,
