Skip to content

kabukit.utils.concurrent

source module kabukit.utils.concurrent

Functions

source async collect[R](awaitables: Iterable[Awaitable[R]], /, max_concurrency: int | None = None) → AsyncIterator[R]

source async collect_fn[T, R](function: Callable[[T], Awaitable[R]], args: Iterable[T], /, max_concurrency: int | None = None) → AsyncIterator[R]

source async concat(awaitables: Iterable[Awaitable[DataFrame]], /, max_concurrency: int | None = None) → DataFrame

source async concat_fn[T](function: Callable[[T], Awaitable[DataFrame]], args: Iterable[T], /, max_concurrency: int | None = None) → DataFrame

source async get_stream(client: Client, resource: str, args: list[Any], max_concurrency: int | None = None) → AsyncIterator[DataFrame]

source async get(cls: type[Client], resource: str, args: Iterable[Any], /, max_items: int | None = None, max_concurrency: int | None = None, progress: Progress | None = None, callback: Callback | None = None) → DataFrame

各種データを取得し、単一のDataFrameにまとめて返す。

Parameters

  • cls : type[Client] — 使用するClientクラス。JQuantsClientやEdinetClientなど、Clientを継承したクラス

  • resource : str — 取得するデータの種類。Clientのメソッド名から"get_"を除いたものを指定する。

  • args : Iterable[Any] — 取得対象の引数のリスト。

  • max_items : int | None, optional — 取得数する上限。

  • max_concurrency : int | None, optional — 同時に実行するリクエストの最大数。指定しないときはデフォルト値が使用される。

  • progress : Progress | None, optional — 進捗表示のための関数。tqdm, marimoなどのライブラリを使用できる。指定しないときは進捗表示は行われない。

  • callback : Callback | None, optional — 各DataFrameに対して適用するコールバック関数。指定しないときはそのままのDataFrameが使用される。

Returns

  • DataFrame —

    すべての情報を含む単一のDataFrame。