DataFrame kann sich nicht in Funktionen multipieren und referenzierenPython

Python-Programme
Anonymous
 DataFrame kann sich nicht in Funktionen multipieren und referenzieren

Post by Anonymous »

Ich habe einen PANDAS -Datenrahmen mit Spalten, die nacheinander berechnet werden müssen. Spalte A, berechnet Spalte B, die zur Berechnung der Spalte F usw. hilft, usw. Die Verarbeitung kann langsam sein, da Python aufgrund des Gils nur 1 Thread verwendet. Multiprocessing, Referenzcode oben und kann in Code unten verwendet werden. /> Neue Spalten, die in Funktionen erstellt wurden, konnten den obigen Code nicht referenzieren und können in den folgenden Code nicht referenziert werden. Neu zu Python, aber versucht. < /P>

Code: Select all

import pandas as pd
import multiprocessing as mp

## I pull some data

df['Date'] = df['timestamp'].apply(lambda x: pd.to_datetime(x*1000000))
df['volume'] = df['volume_og']
...

def functionone():
df = pd.DataFrame()
df['market_9'] = df.apply(lambda x : "9" if x['Date'] >= x['market_9_start'] and x['Date'] < x['market_9_end'] else None, axis=1)
...

def functiontwo():
df = pd.DataFrame()
...

def functionthree():
df = pd.DataFrame()
df['nine_score'] = df.apply(lambda x : x['strength'] if x['market_9'] == "9" else None, axis=1)
...

fig = make_subplots(specs=[[{"secondary_y": True}]])

fig.add_trace(
go.Bar(
x=df['Date'],
y=df['volume'],
...
), secondary_y=True,
)

if __name__ == '__main__':

p1 = mp.Process(target=functionone)
p2 = mp.Process(target=functontwo)
p3 = mp.Process(target=functionthree)

p1.start()
p2.start()
p3.start()
...

Quick Reply

Change Text Case: 
   
  • Similar Topics
    Replies
    Views
    Last post