flūmine

Build Status

flumine is an open-source, event-based trading framework for sports betting, designed to simplify the development and execution of betting strategies on betting venues. flumine provides efficient handling of data streams, risk management, and execution capabilities.

docs

join betcode slack group (2.5k+ members!)

overview

Event-based Execution: Real-time execution of trading strategies based on incoming market events
Custom Strategy Implementation: Easily define and implement trading strategies
Risk Management: Integrated risk management tools to monitor and limit exposure
Modular Design: Easily extendable and customizable components
Simulation: Simulate strategies/execution using historical data
Paper Trading: Test strategies in a simulated environment before going live
Data: Support for market, order and custom streaming data
Venues: Multi venue / concurrent venue support

venues

Betfair
Betdaq
Betconnect (account/execution functionality)
Tote (in development)
Smarkets (roadmap)
Matchbook (roadmap)
Polymarket (roadmap)
Kalshi (roadmap)
BetDEX (roadmap)

Backtesting Analysis

Tested on Python 3.10, 3.11, 3.12, 3.13 and 3.14.

installation

$ pip install flumine

flumine requires Python 3.10+

setup

Get started...

import betfairlightweight
from flumine import Flumine, BaseStrategy, clients
from flumine.streams.betfairmarketstream import BetfairMarketStream
from betfairlightweight.filters import streaming_market_filter

# Define your strategy here
class ExampleStrategy(BaseStrategy):
    def check_market_book(self, market, market_book) -> bool:
        # process_market_book only executed if this returns True
        return True

    def process_market_book(self, market, market_book):
        # Your strategy logic
        pass

# Initialize your client
trading = betfairlightweight.APIClient("username")
client = clients.BetfairClient(trading)

# Initialize the framework
framework = Flumine(client)

# Add your strategy to the framework with a stream
framework.add_strategy(
    ExampleStrategy(
        stream=BetfairMarketStream(
            market_filter=streaming_market_filter(
                event_type_ids=["7"],
                country_codes=["GB"],
                market_types=["WIN"],
            ),
        )
    )
)

# Start the trading framework
framework.run()

Example strategy with logic and order execution:

import betfairlightweight
from flumine import Flumine, BaseStrategy, clients
from flumine.order.trade import Trade
from flumine.order.order import LimitOrder, OrderStatus
from flumine.markets.market import Market
from flumine.streams.betfairmarketstream import BetfairMarketStream
from betfairlightweight.filters import streaming_market_filter
from betfairlightweight.resources import MarketBook


class ExampleStrategy(BaseStrategy):
    def start(self, flumine) -> None:
        print("starting strategy 'ExampleStrategy'")

    def check_market_book(self, market: Market, market_book: MarketBook) -> bool:
        # process_market_book only executed if this returns True
        if market_book.status != "CLOSED":
            return True

    def process_market_book(self, market: Market, market_book: MarketBook) -> None:
        # process marketBook object
        for runner in market_book.runners:
            if runner.status == "ACTIVE" and runner.last_price_traded < 1.5:
                trade = Trade(
                    market_id=market_book.market_id,
                    selection_id=runner.selection_id,
                    handicap=runner.handicap,
                    strategy=self
                )
                order = trade.create_order(
                    side="LAY",
                    order_type=LimitOrder(price=1.01, size=2.00)
                )
                market.place_order(order)

    def process_orders(self, market: Market, orders: list) -> None:
        for order in orders:
            if order.status == OrderStatus.EXECUTABLE:
                if order.size_remaining == 2.00:
                    market.cancel_order(order, 0.02)  # reduce size to 1.98
                if order.order_type.persistence_type == "LAPSE":
                    market.update_order(order, "PERSIST")
                if order.size_remaining > 0:
                    market.replace_order(order, 1.02)  # move


# Initialize your client
trading = betfairlightweight.APIClient("username")
client = clients.BetfairClient(trading)

# Initialize the framework
framework = Flumine(client)

# Add your strategy to the framework with a stream
framework.add_strategy(
    ExampleStrategy(
        stream=BetfairMarketStream(
            market_filter=streaming_market_filter(
                event_type_ids=["7"],
                country_codes=["GB"],
                market_types=["WIN"],
            ),
        )
    )
)

# Start the trading framework
framework.run()

features

Streaming
Multiple strategies
Multiple clients
Order execution
Paper trading
Simulation
Event simulation (multi market)
Middleware and background workers to enable Scores / RaceCard / InPlayService

dependencies

flumine relies on these libraries:

betfairlightweight - Betfair API support
betdaq-retail - BETDAQ API support
betconnect - BetConnect API support
tenacity - Used for connection retrying (streaming)
python-json-logger - JSON logging
requests - HTTP support
smart-open - Efficient streaming of very large files from/to storages such as S3, including (de)compression

Metadata

Release files for flumine 3.2.7

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for flumine 3.2.7
File	Size	Uploaded
flumine-3.2.7.tar.gz	3.3 MB	Oct 13, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for flumine 3.2.7
File	Interpreter	ABI	Platform	Reset
flumine-3.2.7-py3-none-any.whl 92.1 kB Oct 13, 2026	Python 3	none	any	Details

Total release size: 3.4 MB

Release files / flumine-3.2.7.tar.gz

Download URL	flumine-3.2.7.tar.gz
Size	3.3 MB
Tags	Source
SHA-256 checksum How to use checksums	`26c1b4d7c47d1589af784d676bc7c0e8e7674a10b3819499e70901f899aaa7dc`
BLAKE2b-256 checksum How to use checksums	`6f9c6738e013d5065d095c4b7ad9d92349b8dac96bbfc70fabdd716f170a9ad5`
Upload date	Oct 13, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.10.22`

Release files / flumine-3.2.7-py3-none-any.whl

Download URL	flumine-3.2.7-py3-none-any.whl
Size	92.1 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`59adee84078348b993501be380a3886ac5baca3aff6ca16ce8b9152c27c74fcc`
BLAKE2b-256 checksum How to use checksums	`3cf7eb503072c6a20fb7daf37cd4ec68f7001bf173ca7a4842939ee68eb91c66`
Upload date	Oct 13, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.10.22`