FilesExpand file tree

master

/

async_client.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

55 lines (41 loc) · 1.25 KB

master

/

async_client.py

Copy path

Top

File metadata and controls

• Code
• Blame

55 lines (41 loc) · 1.25 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

import asyncio

import httpx

import time

import zeep

from zeep.transports import AsyncTransport

def run_async():

print("async example")

print("=============")

loop = asyncio.get_event_loop()

client = zeep.AsyncClient("http://localhost:8000/?wsdl")

tasks = [

client.service.slow_request("request-1"), # takes 1 sec

client.service.slow_request("request-2"), # takes 1 sec

]

future = asyncio.gather(*tasks, return_exceptions=True)

st = time.time()

loop.run_until_complete(future)

loop.run_until_complete(client.transport.aclose())

print("time: %.2f" % (time.time() - st))

print("result:", future.result())

print("")

return future

def run_sync():

print("sync example")

print("============")

transport = zeep.Transport(cache=None)

client = zeep.Client("http://localhost:8000/?wsdl", transport=transport)

st = time.time()

result = [

client.service.slow_request("request-1"), # takes 1 sec

client.service.slow_request("request-2"), # takes 1 sec

]

print("Time: %.2f" % (time.time() - st))

print("result:", result)

print("\n")

return result

if __name__ == "__main__":

print("")

#asyncio.run(run_async())

run_async()

run_sync()