Pythonのrequestsを非同期にしてiTunes APIに高速にリクエストを投げるには

import asyncio
import time

#計算を処理する部分
def f(future):
    time.sleep(5) # 時間のかかる処理
    future.set_result("hello")
    return

future = asyncio.futures.Future()
#計算を実行する部分
f(future)

if future.done():
    res = future.result()
    print(res)

import asyncio
import time

def f(future):
    time.sleep(5) # 時間のかかる処理
    future.set_result("hello")
    return

loop = asyncio.get_event_loop()
future = asyncio.futures.Future()
loop.call_soon(f, future)
loop.run_forever()

res = loop.run_until_complete(future)
print(res)

import asyncio
import time

def f(future, tag):
    for _ in range(3):
        time.sleep(1)
        print("waiting for f(%d)" % tag)
    future.set_result("hello %d" % tag)
    return

#イベントループを作成
loop = asyncio.get_event_loop()
futures = []
for tag in range(3):
		#futureオブジェクトを作成
    future = loop.create_future()
		#loop（イベントループ）に関数とfutureと関数の引数を登録する。
    loop.call_soon(f, future, tag)
		# futureの状態はfuturesに格納されて管理する。
    futures += [future]
#イベントループを実際に実行する。ここでgatherでfuturesを配列から*で展開している。
res = loop.run_until_complete(asyncio.gather(*futures))
print(res)

#実行結果
waiting for f(0)
waiting for f(0)
waiting for f(0)
waiting for f(1)
waiting for f(1)
waiting for f(1)
waiting for f(2)
waiting for f(2)
waiting for f(2)
['hello 0', 'hello 1', 'hello 2']

def generator():
    yield 1
    yield 2
    yield 3
    return "END"

gg = generator().__iter__()
print(gg.__next__())
print(gg.__next__())
print(gg.__next__())
try:
    print(gg.__next__())
except StopIteration as e:
    print(e.value)

イテレータ = iter(配列)
要素 = next(イテレータ)

l = [0, 1, 2, 3]  # これはリスト
l_iter = iter(l)  # リストからlist_iteratorを取り出す
next(l_iter)
0
next(l_iter)
1
next(l_iter)
2
next(l_iter)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
StopIteration

def my_for(iterable, iter_func):
     it = iter(iterable)
     try:
         while True:
             el = next(it)
             iter_func(el)
     except StopIteration:
         pass

def print_pow(el):
     print(el ** 2)

my_for([0, 1, 2, 3], print_pow)

#実行結果
0
1
4
9

class Test():
	def __init__():
		#ここに色々処理を書き込めば初期化時に処理を追加出来る（オーバライド）

class Foo:
    def __new__(cls):
        print('__new__')
        self = super().__new__(cls)  # インスタンス生成を行う典型的なコード
        self.attr = 'set in __new__'  # ここでしかできない初期化処理を書いてもよい
        return self  # 生成したインスタンスを返す

    def __init__(self, name='foo'):
        print('__init__')
        self.name = name  # インスタンスの初期化処理

    def __del__(self):
        #super().__del__()  # 基底クラスに__del__メソッドがあれば必ず呼び出す
        print('__del__')  # インスタンスが破壊されるときに行う処理

foo = Foo()  # '__new__'と'__init__'が表示される
print('foo.attr:', foo.attr)  # 'foo.attr: set in __new__'
bar = foo
print('bar.name:', bar.name)  # 'bar.name: foo'
print('del foo')  # この時点ではまだ生成したインスタンスには別名がある
del foo
print('del bar')
del bar  # '__del__'：この時点でインスタンスを束縛する名前がなくなる

class Test():
	def __init__(self):
		pass

class Test():
	def __new__(cls):
		self = super().__new__(cls)
		return self

	def __init__(self):
		pass

class NumberedTuple(tuple):
    def __new__(cls, iterable):
				#引数が['foo','bar', 'baz']の場合
        tmp = [(idx, value) for idx, value in enumerate(iterable)]#こんな感じになる：[(0, 'foo'), (1, 'bar'), (2, 'baz')]
        self = super().__new__(cls, tmp)
        return self

nt = NumberedTuple(['foo','bar', 'baz'])
print(nt)  # ((0, 'foo'), (1, 'bar'), (2, 'baz'))

r = range(3)
print(type(r))

#実行結果
<class 'range'>

r = range(3)
print(dir(r))

#実行結果
['__bool__', '__class__', '__contains__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__getitem__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__iter__', '__le__', '__len__', '__lt__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__reversed__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', 'count', 'index', 'start', 'step', 'stop']

r = range(3)

range_iter = r.__iter__()  # イテレータを取り出す
range_iter2 = iter(r)  # イテレータを取り出す

print(type(range_iter))
print(type(range_iter2))

#実行結果
<class 'range_iterator'>
<class 'range_iterator'>

#さらに
print(range_iter.__next__())  # range_iterから次の値を取得
print(range_iter.__next__())  # range_iterから次の値を取得
print(next(range_iter2))  # range_iter2から次の値を取得
print(next(range_iter2))  # range_iter2から次の値を取得

#実行結果
0
1
0
1

#さらにrange_iterの値を全て取り出す
print(next(range_iter))  # range(3)で作成したので、要素はここで尽きる
print(next(range_iter))  # これ以降は例外が発生する

#実行結果
2
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
StopIteration

class CountUpIterator:
    def __init__(self, limit=5):
        self.limit = limit
        self.counter = -1
    def __iter__(self):
        print('__iter__ method called')
        return self
    def __next__(self):
        print('__next__ method called')
        self.counter += 1
        if self.counter >= self.limit:
            raise StopIteration()
        return self.counter

countup_iter = CountUpIterator(3)
countup_iter2 = iter(countup_iter)
print(countup_iter is countup_iter2)

#実行結果
__iter__method called
True

print(next(countup_iter))
print(countup_iter2.__next__())
print(next(countup_iter2))
print(countup_iter.__next__())

#実行結果
__next__method called
0
__next__method called
1
__next__method called
2
__next__method called
StopItaration

def generator():
    yield 1
    yield 2
    yield 3
    return "END"

gg = generator().__iter__()#generator関数からイテレータを生成する。
print(gg.__next__())
print(gg.__next__())
print(gg.__next__())

try:
    print(gg.__next__())
except StopIteration as e:
    print(e.value)

#実行結果
1
2
3
END

def test():
	c = 100 + 200
	return c

def test2():
	for i in range(3):
		c = i + 200
		yield c

	c = 10 + 20
	yield c

test2 = test2() #generatorオブジェクト生成
print(dir(test2))#test2のオブジェクトには__next__メソッドがある事を確認する。

print('1回目')
print(test())
print(test2.__next__())#next(test2)でもいい

print('2回目')
print(test())
print(test2.__next__())#next(test2)でもいい

print('3回目')
print(test())
print(test2.__next__())#next(test2)でもいい

#実行結果
1回目
300
300 
2回目
300
30 #yieldの場合1回目と値が異なる。
3回目
300
Traceback (most recent call last):
  File "yieldIter.py", line 26, in <module>
    print(test2.__next__())#next(test2)でもいい
StopIteration

def test2():
    for i in range(3):
        c = i + 200
        yield c
        print(f'hello：{i}')

    c = 10 + 20
    yield c

test2 = test2() #generatorオブジェクト生成

print('1回目')
print(test2.__next__())#next(test2)でもいい

print('2回目')
print(test2.__next__())#next(test2)でもいい

print('3回目')
print(test2.__next__())#next(test2)でもいい

print('4回目')
print(test2.__next__())#next(test2)でもいい

#実行結果
1回目
200
2回目
hello：0
201
3回目
hello：1
202
4回目
hello：2
30

def generator1():
    yield 'one'
 
def generator2():
    yield 'two'
 
def generator(g1, g2):
    yield from g1
    yield from g2
 
gen = generator(generator1(), generator2())
 
for x in gen:
    print(x)

#実行結果
one 
two

def generator2():
    yield 1
    yield 2
    yield 3
    return "END"

def generator():
    a = yield from generator2()
    return a

gg = generator().__iter__()
print(gg.__next__())
print(gg.__next__())
print(gg.__next__())
try:
    print(gg.__next__())
except StopIteration as e:
    print(e.value)

#実行結果
#実行結果
1
2
3
END

import asyncio
import time

def f(tag):
    for _ in range(3):
        yield
        time.sleep(1)
        print("waiting for f(%d)" % tag)
    return "hello %d" % tag

loop = asyncio.get_event_loop()
tasks = []
for tag in range(3):
    task = f(tag)#最初のyieldのおかげでタスクが3つ出来る。
    tasks += [task]
res = loop.run_until_complete(asyncio.gather(*tasks))#イベントループを処理が全て終了するまで実行
print(res)

#実行結果 1秒毎に結果が出力される。
# yield 出力はされないが最初はyieldまで実行されている
# yield
# yield
waiting for f(0)
waiting for f(1)
waiting for f(2)
waiting for f(0)
waiting for f(1)
waiting for f(2)
waiting for f(0)
waiting for f(1)
waiting for f(2)
['hello 0', 'hello 1', 'hello 2']

import asyncio
import time

def f(tag):
    for _ in range(3):
        print(f'yield：{tag}')
        print(f'_の中身：{_}')
        yield
        time.sleep(1)
        print("waiting for f(%d)" % tag)
    return "hello %d" % tag

loop = asyncio.get_event_loop()
tasks = []
for tag in range(3):
    task = f(tag)
    tasks += [task]
res = loop.run_until_complete(asyncio.gather(*tasks))
print(res)

#実行結果
yield：0#ここが最初のyield3行
_の中身：0
yield：1#ここが最初のyield3行
_の中身：0
yield：2#ここが最初のyield3行
_の中身：0
#waiting for 手前までは一気に出力される。
#手前で1秒待ってから次の処理に移るその際イベントループ自体が止まるので非同期処理にならない。
waiting for f(0) #loop.run_until_completeによってタスクが実行される。

yield：0
_の中身：1#ここでイベントループが0→1に切り替わる

waiting for f(1)#切り替わって2回目のforループのyieldまで処理を進める。この動作を繰り返す。
yield：1
_の中身：1#ここで再びイベントループが1→2に切り替わる。

waiting for f(2)#f(2)の2回目のforループのyieldまで処理を進める。
yield：2
_の中身：1

waiting for f(0)
yield：0
_の中身：2

waiting for f(1)
yield：1
_の中身：2

waiting for f(2)
yield：2
_の中身：2

waiting for f(0)
waiting for f(1)
waiting for f(2)
['hello 0', 'hello 1', 'hello 2']

import asyncio

def f(tag):
    for _ in range(3):
        print(f'yield：{tag} {_}')
        yield 
    return "hello %d" % tag

loop = asyncio.get_event_loop()
res = loop.run_until_complete(f(0))
print(res)

#実行結果
yield：0 0
yield：0 1
yield：0 2
hello 0

import asyncio
import time

def my_sleep(delay):
    def _cb_set_result(fut):
        fut.set_result(None)
    loop = asyncio.get_running_loop()#現在実行中のイベントループを返すなければエラーが発生
    future = loop.create_future()#futureオブジェクトを作成する。
    h = loop.call_later(delay, _cb_set_result, future)#delay分待ってから_cd_set_resultを実行する。
    #今回の場合は1秒後に_cd_set_resultが実行される。
		yield from future #futureインスタンスがイテレータなのでyield fromを使用する。

def f(tag):
    for i in range(3):
        yield from my_sleep(1)#なぜこれで1秒待つとまとめて3行出力されるのか分からん。
        print("waiting for f(%d)" % tag)
    return "hello %d" % tag

loop = asyncio.get_event_loop() #イベントループ作成
tasks = [f(n) for n in range(3)] #3つf()のタスクを作成
ret = loop.run_until_complete(asyncio.gather(*tasks))
print(ret)

#実行結果
waiting for f(0)
waiting for f(1)
waiting for f(2)
#1秒後
waiting for f(0)
waiting for f(1)
waiting for f(2)
#1秒後と間隔を開けて更新される。
waiting for f(0)
waiting for f(1)
waiting for f(2)
['hello 0', 'hello 1', 'hello 2']

import asyncio

loop = asyncio.get_event_loop()
loop_2 = asyncio.get_event_loop()
print(loop is loop_2) 

#実行結果
True

import asyncio

loop = asyncio.get_event_loop()
loop_2 = asyncio.new_event_loop()
print(loop is loop_2) 

#実行結果
False

class Future:
    #....
    def __iter__(self):
        yield self

import asyncio
import time

async def f(tag):
    for i in range(3):
        await asyncio.sleep(1)#ここで処理が中断して1秒後に再開する。
        print("waiting for f(%d)" % tag)
    return "hello %d" % tag

loop = asyncio.get_event_loop()
tasks = [f(n) for n in range(3)]
ret = loop.run_until_complete(asyncio.gather(*tasks))
print(ret)

import time
import json
import asyncio
import requests

async def f(url):
	res = await loop.run_in_executor(None, requests.get, url)
	return res.json()

songName = '愛のままに feat. 唾奇'

urls = [f'https://itunes.apple.com/search?term={songName}&media=music&entity=song&country=jp&lang=ja_jp&limit=10', f'https://itunes.apple.com/search?term={songName}&media=music&entity=song&limit=10']
loop = asyncio.get_event_loop()
tasks = [f(url) for url in urls]
start = time.time()
ret = loop.run_until_complete(asyncio.gather(*tasks))
print(ret)
end = time.time() - start
print(f'実行時間：{end}')

#実行結果
[{'resultCount': 1, 'results': [{'wrapperType': 'track', 'kind': 'song', 'artistId': 370539771, 'collectionId': 1468067871, 'trackId': 1468068067, 'artistName': 'BASI', 'collectionName': '切愛', 'trackName': '愛のままに feat. 唾奇', 'collectionCensoredName': '切愛', 'trackCensoredName': '愛のままに feat. 唾奇', 'artistViewUrl': 'https://music.apple.com/jp/artist/basi/370539771?uo=4', 'collectionViewUrl': 'https://music.apple.com/jp/album/%E6%84%9B%E3%81%AE%E3%81%BE%E3%81%BE%E3%81%AB-feat-%E5%94%BE%E5%A5%87/1468067871?i=1468068067&uo=4', 'trackViewUrl': 'https://music.apple.com/jp/album/%E6%84%9B%E3%81%AE%E3%81%BE%E3%81%BE%E3%81%AB-feat-%E5%94%BE%E5%A5%87/1468067871?i=1468068067&uo=4', 'previewUrl': 'https://audio-ssl.itunes.apple.com/itunes-assets/AudioPreview123/v4/1a/7a/28/1a7a288f-5107-f412-9772-81481d3bf921/mzaf_4891237580224207650.plus.aac.p.m4a', 'artworkUrl30': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/30x30bb.jpg', 'artworkUrl60': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/60x60bb.jpg', 'artworkUrl100': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/100x100bb.jpg', 'collectionPrice': 2037.0, 'trackPrice': 255.0, 'releaseDate': '2019-06-26T07:00:00Z', 'collectionExplicitness': 'notExplicit', 'trackExplicitness': 'notExplicit', 'discCount': 1, 'discNumber': 1, 'trackCount': 12, 'trackNumber': 11, 'trackTimeMillis': 266333, 'country': 'JPN', 'currency': 'JPY', 'primaryGenreName': 'ヒップホップ／ラップ', 'isStreamable': True}]}, {'resultCount': 1, 'results': [{'wrapperType': 'track', 'kind': 'song', 'artistId': 370539771, 'collectionId': 1468067871, 'trackId': 1468068067, 'artistName': 'BASI', 'collectionName': 'Setsuai', 'trackName': 'Ainomamani (feat. Tsubaki)', 'collectionCensoredName': 'Setsuai', 'trackCensoredName': 'Ainomamani (feat. Tsubaki)', 'artistViewUrl': 'https://music.apple.com/us/artist/basi/370539771?uo=4', 'collectionViewUrl': 'https://music.apple.com/us/album/ainomamani-feat-tsubaki/1468067871?i=1468068067&uo=4', 'trackViewUrl': 'https://music.apple.com/us/album/ainomamani-feat-tsubaki/1468067871?i=1468068067&uo=4', 'previewUrl': 'https://audio-ssl.itunes.apple.com/itunes-assets/AudioPreview123/v4/1a/7a/28/1a7a288f-5107-f412-9772-81481d3bf921/mzaf_4891237580224207650.plus.aac.p.m4a', 'artworkUrl30': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/30x30bb.jpg', 'artworkUrl60': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/60x60bb.jpg', 'artworkUrl100': 'https://is2-ssl.mzstatic.com/image/thumb/Music123/v4/0f/93/e2/0f93e249-6b57-6d55-8550-9f8a997ccd4a/source/100x100bb.jpg', 'collectionPrice': 12.99, 'trackPrice': 1.29, 'releaseDate': '2019-06-26T07:00:00Z', 'collectionExplicitness': 'notExplicit', 'trackExplicitness': 'notExplicit', 'discCount': 1, 'discNumber': 1, 'trackCount': 12, 'trackNumber': 11, 'trackTimeMillis': 266333, 'country': 'USA', 'currency': 'USD', 'primaryGenreName': 'Hip-Hop/Rap', 'isStreamable': True}]}]
実行時間：0.16942214965820312