1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
"""
Synchronous blocking engine that processes requests one by one.
"""
import requests
from . import BaseEngine
class SyncEngine(BaseEngine):
@staticmethod
def create_session(**params):
session = requests.Session()
for param in params:
setattr(session, param, params[param])
return session
def process_bulk_request(self, method, url, container, bulk_params):
return [resource for params in bulk_params for resource in self.request(method, url, params=params)[container]]
|
