Python-如何提交并发API请求以进行交易目的

Question

因此，我在CSV中有一系列看起来像这样的工具的清单：

EUR_HUF
EUR_DKK
USD_MXN
GBP_USD
CAD_CHF
EUR_GBP
GBP_CHF 
...

通过执行此API请求，可以在单个工具上提交订单：

import asyncio
import aiohttp
import logging
import json

headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer 83da58ee4d8b630115ba04368ed6916c-db53699ac5f596bfd495b835571ed878"
}

async def post(session,instrument):
    headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer 83da58ee4d8b630115ba04368ed6916c-db53699ac5f596bfd495b835571ed878"
    },

    data = {
        "order": {
            "units": 1,
            "instrument": instrument,
            "timeInForce": "FOK",
            "type": "MARKET",
            "positionFill": "DEFAULT"
        }
    }
    async with session.post(f"https://api-fxpractice.oanda.com/v3/accounts/101-004-22347481-001/orders") as response:
        return await response.text()


async def pre_post(instruments):
    data = {
        "order": {
            "units": 1,
            "instrument": instruments,
            "timeInForce": "FOK",
            "type": "MARKET",
            "positionFill": "DEFAULT"
        }
    }
    async with aiohttp.ClientSession(headers=headers) as session:
        results = await asyncio.gather(*[post(session,instrument) for instrument in instruments])
        return results


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    instruments = [ "EUR_HUF",
        # "EUR_DKK",
        # "USD_MXN",
        # "GBP_USD",
        # "CAD_CHF",
        # "EUR_GBP",
        # "GBP_CHF"
        ]
    response = loop.run_until_complete(pre_post(instruments))
    print(response)

现在我想同时提交仪器CSV中所有工具的订单。我已经研究了螺纹和AIOHTTP，但我不确定如何将其应用于我的情况。

任何指导或示例都将不胜

感激

Answer 1

在下面，您将看到一个示例，说明如何同时发送请求。
请注意，此代码尚未完成。
acc_num和令牌缺少，因为它们在您的问题中未指定。这应该给您一个想法，并且不需要太多来满足您的需求。

import asyncio
import aiohttp


async def post(session, token, acc_num, instrument):
    headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer " + token
    }
    data = {
        "order": {
            "units": 1,
            "instrument": instrument,
            "timeInForce": "FOK",
            "type": "MARKET",
            "positionFill": "DEFAULT"
        }
    }
    async with session.post(f"https://api-fxpractice.oanda.com/v3/accounts/{acc_num}/orders") as response:
        return await response.text()


async def pre_post(instruments):
    async with aiohttp.ClientSession() as session:
        results = await asyncio.gather(*[fetch(session, token, acc_num, instrument) for instrument in instruments])
        return results


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    instruments = [ "EUR_HUF",
        "EUR_DKK",
        "USD_MXN",
        "GBP_USD",
        "CAD_CHF",
        "EUR_GBP",
        "GBP_CHF" 
        ]
    response = loop.run_until_complete(pre_post(instruments))
    print(response)

从

Answer 2

多亏了Kevinssadev，我设法修复了它。这是完整的解决方案

import asyncio
import aiohttp
import logging
import json

headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer 83da58ee4d8b630115ba04368ed6916c-db53699ac5f596bfd495b835571ed878"
}

async def post(session,instrument):
    headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer 83da58ee4d8b630115ba04368ed6916c-db53699ac5f596bfd495b835571ed878"
    },

    data = {
        "order": {
            "units": 1,
            "instrument": instrument,
            "timeInForce": "FOK",
            "type": "MARKET",
            "positionFill": "DEFAULT"
        }
    }
    async with session.post(f"https://api-fxpractice.oanda.com/v3/accounts/101-004-22347481-001/orders",data=json.dumps(data)) as response:
        return await response.text()


async def pre_post(instruments):
    data = {
        "order": {
            "units": 1,
            "instrument": instruments,
            "timeInForce": "FOK",
            "type": "MARKET",
            "positionFill": "DEFAULT"
        }
    }
    async with aiohttp.ClientSession(headers=headers) as session:
        results = await asyncio.gather(*[post(session,instrument) for instrument in instruments])
        return results


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    instruments = [ "EUR_HUF",
        "EUR_DKK",
        "USD_MXN",
        "GBP_USD",
        "CAD_CHF",
        "EUR_GBP",
        "GBP_CHF"
        ]
    response = loop.run_until_complete(pre_post(instruments))
    print(response)