Klar, aber wie bekommt ein Client mit, dass dieser upgedatet wurde?

Ok, wenn das doch so kompliziert ist, bleib ich dabei und schreib bei jedem Datenbank-Update etwas in eine Datei und frage dann in streamlit den Timestamp der Datei ab

MariaDB wäre gut, sonst müsste ich hier alles umstellen

Hi, ich schreibe per sqlalchemy und pandas regelmäßig Dataframes in eine Datenbank (mariadb) und lese diese dann in einem anderen Script wieder aus (streamlit). Wie kann es hinbekommen, dass das auslesende Programm ein Datenbankupdate mitbekommt? Quasi auslesen, sobald die ein neues Dataframe in die...

Ok, grad mal etwas rumprobiert, liegt wirklich an einem nicht funktionierendem Ticker. Scheint mein "if len(result) > 0:" nicht zu funktionieren.
Werd mal nach einer anderen Möglichkeit suchen, das Ticker-Symbol zu validieren.

Hallo, ich muss diesen Thread nochmal hochholen, weil momentan Problem auftreten. Folgende Meldung bekomm ich: multiprocessing.pool.RemoteTraceback: """ Traceback (most recent call last): File "/usr/lib/python3.8/multiprocessing/pool.py", line 125, in worker result = (True, ...

Ich habe jetzt mal versucht, die Aufrufe von contractDetails und securityDefinitionOptionParameter zu trennen per time.sleep, aber immernoch ohne Erfolg. from ibapi.client import EClient from ibapi.wrapper import EWrapper from ibapi.common import SetOfString from ibapi.common import SetOfFloat from ...

die Funktion exp() spuckt mir die conid aus, das funktioniert.

Ich glaube, ich muss das Script nochmal umbauen, da beide Funktionen wohl gleichzeitig ausgeführt werden und nicht nacheinander.

Ich bekomme ja self.conid aus "self.reqContractDetails(1, contract)) per
Wenn ich aber self.conid an self.reqSecDefOptParams übergebe, ist sie leer.

Wahrscheinlich hab ich einen Denkfehler, ich suche weiter.

Hab das Script etwas angepasst: from ibapi.client import EClient from ibapi.wrapper import EWrapper from ibapi.common import SetOfString from ibapi.common import SetOfFloat from ibapi.contract import Contract from threading import Timer from datetime import datetime class TestApp(EWrapper, EClient):...

Ich glaub, jetzt komm ich nicht mehr mit. Kannst du das mal kurz beschreiben?

Der Grund für exp() ist, dass ich diese Funktion später aus einem anderen Script aufrufen möchte und dabei die Variable "stock" übergeben will. Sprich exp('AAPL') und das Script soll mir die conid per "def contractDetails" ermiiteln, welche ich für "def securityDefinitionOpt...

Hallo, folgendes Script hab ich erstellt: def exp(stock): from ibapi.client import EClient from ibapi.wrapper import EWrapper from ibapi.common import SetOfString from ibapi.common import SetOfFloat from ibapi.contract import Contract from threading import Timer from datetime import datetime class T...

Hi, ich habe ein Dataframe, welches ich per streamlit visualisiere, hier ein Teil des Codes: ... def style_negative(v, props=''): return props if v < 0 else None def style_positive(v, props=''): return props if v > 0 else None ... s1 = watchlist.style.applymap(style_negative, props='background-color...

Hab nicht den kompletten Code gepostet, sondern nur den Teil den ich geändert habe.

Hab jetzt einen neuen Weg getestet, der wohl erstmal funktioniert, zwar kein schöner Code, aber läuft. def ibi(tickers): i = 0 ib = IB() id = random.randint(100,300) ib.connect('127.0.0.1', 7496, clientId=id, timeout=10.0) df_tickers = pd.DataFrame() results = [] if ib.isConnected: for ticker in tic...

Ich will nicht das Maximum herausholen, das liegt glaub ich bei 32 Verbindungen oder sogar mehr, mir reichen 10.

In Summe sind 20 Coroutinen drin, wenn die Probleme auftauchen.

Mit diesem Code klappt der Aufruf: for start in range(0, amount, parts): results = await asyncio.gather(*[ibi(data, num) for num, data in enumerate(ticker[start:start+parts], 100)]) Damit nicht: for start in range(0, amount, parts): for num, data in enumerate(ticker[start:start+parts], 100): ticker_...

Weil mir dabei immer die IB-API abstürzt, da scheinbar zu viele Anfrage auf einmal kommen.
Es wird scheinbar nicht auf die Ergebnisse der ersten 10 Anfragen gewartet, sondern gleich die nächsten 10
hinterher geschickt, und dann doppeln sich die Client-IDs und es kommt der Fehler der API.

Der Aufruf per ib_insync funktioniert, der du yahoo ebenso, jedenfalls nacheinander. Das beide parallel laufen, klappt noch nicht. Mein Aufruf der yahoo-Funktion in der main() yahoo_results = await asyncio.gather(*[yahoo(stocks) for stocks in ticker]) df_yahoo_results = pd.DataFrame(yahoo_results, c...