crie uma matriz NxN a partir de uma coluna pandas

11

Eu tenho dataframe com cada linha com um valor de lista.

id     list_of_value
0      ['a','b','c']
1      ['d','b','c']
2      ['a','b','c']
3      ['a','b','c']

eu tenho que fazer um cálculo de uma pontuação com uma linha e contra todas as outras linhas

Por exemplo:

Step 1: Take value of id 0: ['a','b','c'],
Step 2: find the intersection between id 0 and id 1 , 
        resultant = ['b','c']
Step 3: Score Calculation => resultant.size / id.size

repita a etapa 2,3 entre os ID 0 e 1,2,3, da mesma forma para todos os IDs.

e crie um quadro de dados N x N; tal como este:

-  0  1    2  3
0  1  0.6  1  1
1  1  1    1  1 
2  1  1    1  1
3  1  1    1  1

No momento, meu código tem apenas um para loop:

def scoreCalc(x,queryTData):
    #mathematical calculation
    commonTData = np.intersect1d(np.array(x),queryTData)
    return commonTData.size/queryTData.size

ids = list(df['feed_id'])
dfSim = pd.DataFrame()

for indexQFID in range(len(ids)):
    queryTData = np.array(df.loc[df['id'] == ids[indexQFID]]['list_of_value'].values.tolist())

    dfSim[segmentDfFeedIds[indexQFID]] = segmentDf['list_of_value'].apply(scoreCalc,args=(queryTData,))

Existe uma maneira melhor de fazer isso? Posso apenas escrever uma função de aplicar em vez de fazer uma iteração de loop for. posso torná-lo mais rápido?

Sriram Arvind Lakshmanakumar
fonte
11
editou a pergunta, @Babydesta
Sriram Arvind Lakshmanakumar
11
não é 6, é 0,6, resultant.size = 2, id.size = 3
Sriram Arvind Lakshmanakumar
Quanto tempo duram seus dados? e totalmente em quantos valores ocorrem list_of_value?
Quang Hoang
máximo de 20 valores em cada lista_de_valor
Sriram Arvind Lakshmanakumar
Não em cada um list_of_value. Quero dizer no total, em todas as linhas.
Quang Hoang

Respostas:

7

Se seus dados não forem muito grandes, você poderá get_dummiescodificar os valores e fazer uma multiplicação de matrizes:

s = pd.get_dummies(df.list_of_value.explode()).sum(level=0)
s.dot(s.T).div(s.sum(1))

Resultado:

          0         1         2         3
0  1.000000  0.666667  1.000000  1.000000
1  0.666667  1.000000  0.666667  0.666667
2  1.000000  0.666667  1.000000  1.000000
3  1.000000  0.666667  1.000000  1.000000

Atualização : Aqui está uma breve explicação para o código. A idéia principal é transformar as listas fornecidas em um código quente:

   a  b  c  d
0  1  1  1  0
1  0  1  1  1
2  1  1  1  0
3  1  1  1  0

Depois disso, o tamanho da interseção das duas linhas, digamos, 0e 1é apenas o produto escalar, porque um caractere pertence às duas linhas se e somente se é representado por 1ambas.

Com isso em mente, primeiro uso

df.list_of_value.explode()

para transformar cada célula em uma série e concatenar todas essas séries. Resultado:

0    a
0    b
0    c
1    d
1    b
1    c
2    a
2    b
2    c
3    a
3    b
3    c
Name: list_of_value, dtype: object

Agora, usamos pd.get_dummiesessa série para transformá-la em um dataframe com um código quente:

   a  b  c  d
0  1  0  0  0
0  0  1  0  0
0  0  0  1  0
1  0  0  0  1
1  0  1  0  0
1  0  0  1  0
2  1  0  0  0
2  0  1  0  0
2  0  0  1  0
3  1  0  0  0
3  0  1  0  0
3  0  0  1  0

Como você pode ver, cada valor tem sua própria linha. Como queremos combinar aqueles que pertencem à mesma linha original em uma linha, podemos apenas somar pelo índice original. portanto

s = pd.get_dummies(df.list_of_value.explode()).sum(level=0)

fornece o quadro de dados codificado em binário que queremos. A próxima linha

s.dot(s.T).div(s.sum(1))

é exatamente como a sua lógica: s.dot(s.T)calcula os produtos pontilhados por linhas e depois .div(s.sum(1))divide as contagens por linhas.

Quang Hoang
fonte
Dataframe de 12k linhas
Sriram Arvind Lakshmanakumar
@SriramArvindLakshmanakumar com 12k linhas, você terminaria com o 12k x 12kdataframe. Deve ficar bom se você tiver algumas centenas de valores exclusivos.
Quang Hoang
poderia explicar o código também?
Sriram Arvind Lakshmanakumar
Claro, mas funciona?
Quang Hoang
11
@SriramArvindLakshmanakumar Obrigado por aceitar minha solução. Consulte a atualização para obter uma explicação e lógica de pensamento.
Quang Hoang
3

Tente isto

range_of_ids = range(len(ids))

def score_calculation(s_id1,s_id2):
    s1 = set(list(df.loc[df['id'] == ids[s_id1]]['list_of_value'])[0])
    s2 = set(list(df.loc[df['id'] == ids[s_id2]]['list_of_value'])[0])
    # Resultant calculation s1&s2
    return round(len(s1&s2)/len(s1) , 2)


dic = {indexQFID:  [score_calculation(indexQFID,ind) for ind in range_of_ids] for indexQFID in range_of_ids}
dfSim = pd.DataFrame(dic)
print(dfSim)

Resultado

     0        1      2       3
0   1.00    0.67    1.00    1.00
1   0.67    1.00    0.67    0.67
2   1.00    0.67    1.00    1.00
3   1.00    0.67    1.00    1.00

Você também pode fazer o seguinte

dic = {indexQFID:  [round(len(set(s1)&set(s2))/len(s1) , 2) for s2 in df['list_of_value']] for indexQFID,s1 in zip(df['id'],df['list_of_value']) }
dfSim = pd.DataFrame(dic)
print(dfSim)
FAHAD SIDDIQUI
fonte
2

Use a compreensão da lista aninhada na lista de conjuntos s_list. Na compreensão da lista, use a intersectionoperação para verificar a sobreposição e obter o comprimento de cada resultado. Por fim, construa o quadro de dados e divida-o pelo comprimento de cada lista emdf.list_of_value

s_list =  df.list_of_value.map(set)
overlap = [[len(s1 & s) for s1 in s_list] for s in s_list]

df_final = pd.DataFrame(overlap) / df.list_of_value.str.len().to_numpy()[:,None]

Out[76]:
          0         1         2         3
0  1.000000  0.666667  1.000000  1.000000
1  0.666667  1.000000  0.666667  0.666667
2  1.000000  0.666667  1.000000  1.000000
3  1.000000  0.666667  1.000000  1.000000

Caso haja valores duplicados em cada lista, você deve usar em collections.Countervez de set. Alterei os dados de amostra id = 0 para ['a','a','c']e id = 1 para['d','b','a']

sample df:
id     list_of_value
0      ['a','a','c'] #changed
1      ['d','b','a'] #changed
2      ['a','b','c']
3      ['a','b','c']

from collections import Counter

c_list =  df.list_of_value.map(Counter)
c_overlap = [[sum((c1 & c).values()) for c1 in c_list] for c in c_list]

df_final = pd.DataFrame(c_overlap) / df.list_of_value.str.len().to_numpy()[:,None]


 Out[208]:
          0         1         2         3
0  1.000000  0.333333  0.666667  0.666667
1  0.333333  1.000000  0.666667  0.666667
2  0.666667  0.666667  1.000000  1.000000
3  0.666667  0.666667  1.000000  1.000000
Andy L.
fonte
2

Atualizada

Como existem muitas soluções candidatas propostas, parece uma boa ideia fazer uma análise de tempo. Gerei alguns dados aleatórios com 12 mil linhas, conforme solicitado pelo OP, mantendo os 3 elementos por conjunto, mas expandindo o tamanho do alfabeto disponível para preencher os conjuntos. Isso pode ser ajustado para corresponder aos dados reais.

Deixe-me saber se você tem uma solução que gostaria de testar ou atualizar.

Configuração

import pandas as pd
import random

ALPHABET = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ'

def random_letters(n, n_letters=52):
    return random.sample(ALPHABET[:n_letters], n)

# Create 12k rows to test scaling.
df = pd.DataFrame([{'id': i, 'list_of_value': random_letters(3)} for i in range(12000)])

Vencedor Atual

def method_quang(df): 
    s = pd.get_dummies(df.list_of_value.explode()).sum(level=0) 
    return s.dot(s.T).div(s.sum(1)) 

%time method_quang(df)                                                                                                                                                                                                               
# CPU times: user 10.5 s, sys: 828 ms, total: 11.3 s
# Wall time: 11.3 s
# ...
# [12000 rows x 12000 columns]

Competidores

def method_mcskinner(df):
    explode_df = df.set_index('id').list_of_value.explode().reset_index() 
    explode_df = explode_df.rename(columns={'list_of_value': 'value'}) 
    denom_df = explode_df.groupby('id').size().reset_index(name='denom') 
    numer_df = explode_df.merge(explode_df, on='value', suffixes=['', '_y']) 
    numer_df = numer_df.groupby(['id', 'id_y']).size().reset_index(name='numer') 
    calc_df = numer_df.merge(denom_df, on='id') 
    calc_df['score'] = calc_df['numer'] / calc_df['denom'] 
    return calc_df.pivot('id', 'id_y', 'score').fillna(0) 

%time method_mcskinner(df)
# CPU times: user 29.2 s, sys: 9.66 s, total: 38.9 s
# Wall time: 29.6 s
# ...
# [12000 rows x 12000 columns]
def method_rishab(df): 
    vals = [[len(set(val1) & set(val2)) / len(val1) for val2 in df['list_of_value']] for val1 in df['list_of_value']]
    return pd.DataFrame(columns=df['id'], data=vals)

%time method_rishab(df)                                                                                                                                                                                                              
# CPU times: user 2min 12s, sys: 4.64 s, total: 2min 17s
# Wall time: 2min 18s
# ...
# [12000 rows x 12000 columns]
def method_fahad(df): 
    ids = list(df['id']) 
    range_of_ids = range(len(ids)) 

    def score_calculation(s_id1,s_id2): 
        s1 = set(list(df.loc[df['id'] == ids[s_id1]]['list_of_value'])[0]) 
        s2 = set(list(df.loc[df['id'] == ids[s_id2]]['list_of_value'])[0]) 
        # Resultant calculation s1&s2 
        return round(len(s1&s2)/len(s1) , 2) 

    dic = {indexQFID:  [score_calculation(indexQFID,ind) for ind in range_of_ids] for indexQFID in range_of_ids} 
    return pd.DataFrame(dic) 

# Stopped manually after running for more than 10 minutes.

Postagem original com detalhes da solução

É possível fazer isso pandascom uma auto-junção.

Como outras respostas apontaram, o primeiro passo é descompactar os dados em um formato mais longo.

explode_df = df.set_index('id').list_of_value.explode().reset_index()
explode_df = explode_df.rename(columns={'list_of_value': 'value'})
explode_df
#     id value
# 0    0     a
# 1    0     b
# 2    0     c
# 3    1     d
# 4    1     b
# ...

Nesta tabela, é possível calcular as contagens por ID.

denom_df = explode_df.groupby('id').size().reset_index(name='denom')
denom_df
#    id  denom
# 0   0      3
# 1   1      3
# 2   2      3
# 3   3      3

E então vem a auto-junção, o que acontece na valuecoluna. Isso associa os IDs uma vez para cada valor de interseção, para que os IDs emparelhados possam ser contados para obter os tamanhos de interseção.

numer_df = explode_df.merge(explode_df, on='value', suffixes=['', '_y'])
numer_df = numer_df.groupby(['id', 'id_y']).size().reset_index(name='numer')
numer_df
#     id  id_y  numer
# 0    0     0      3
# 1    0     1      2
# 2    0     2      3
# 3    0     3      3
# 4    1     0      2
# 5    1     1      3
# ...

Esses dois podem ser mesclados e uma pontuação calculada.

calc_df = numer_df.merge(denom_df, on='id')
calc_df['score'] = calc_df['numer'] / calc_df['denom']
calc_df
#     id  id_y  numer  denom     score
# 0    0     0      3      3  1.000000
# 1    0     1      2      3  0.666667
# 2    0     2      3      3  1.000000
# 3    0     3      3      3  1.000000
# 4    1     0      2      3  0.666667
# 5    1     1      3      3  1.000000
# ...

Se você preferir a forma da matriz, isso é possível com a pivot. Essa será uma representação muito maior se os dados forem escassos.

calc_df.pivot('id', 'id_y', 'score').fillna(0)
# id_y         0         1         2         3
# id                                          
# 0     1.000000  0.666667  1.000000  1.000000
# 1     0.666667  1.000000  0.666667  0.666667
# 2     1.000000  0.666667  1.000000  1.000000
# 3     1.000000  0.666667  1.000000  1.000000
mcskinner
fonte
1

Esta solução irá trabalhar eficientemente com qualquer tamanho de dados e qualquer tipo de valores em sua listpalavra sua strou intou de outra forma, também cuidar dos valores repetitivos se houver.

# dummy data
df = pd.DataFrame({'id': [0, 1, 2, 3], 'list_of_value': [['a','b','c'],['d','b','c'], ['a','b','c'], ['a','b','c']]})
# calculating the target values using list comprehension
vals = [[len(set(val1) & set(val2)) / len(val1) for val2 in df['list_of_value']] for val1 in df['list_of_value']]
# new resultant Dataframe
df =  pd.DataFrame(columns=df['id'], data=vals)

Nesse caso, a compreensão da lista tem um desempenho melhor porque não precisa carregar o atributo de acréscimo da lista e chamá-lo como uma função a cada iteração. Em outras palavras, e em geral, as compreensões de lista são mais rápidas porque suspender e retomar o quadro de uma função ou várias funções em outros casos são mais lentas do que a criação de uma lista sob demanda.

Usar uma compreensão de lista no lugar de um loop que não cria uma lista, acumular absurdamente uma lista de valores sem sentido e depois jogá-la fora, geralmente é mais lento por causa da sobrecarga de criar e estender a lista.

Resultado:

id         0         1         2         3
0   1.000000  0.666667  1.000000  1.000000
1   0.666667  1.000000  0.666667  0.666667
2   1.000000  0.666667  1.000000  1.000000
3   1.000000  0.666667  1.000000  1.000000

Tempo de execução:

import timeit

def function():
    df = pd.DataFrame({'id': [0, 1, 2, 3], 'list_of_value': [['a','b','c'],['d','b','c'], ['a','b','c'], ['a','b','c']]})
    vals = [[len(set(val1) & set(val2)) / len(val1) for val2 in df['list_of_value']] for val1 in df['list_of_value']]
    df =  pd.DataFrame(columns=df['id'], data=vals)

print(timeit.timeit(f'{function()}', number=1000000))
# 0.010986731999999999
Rishab P.
fonte
0

Você pode converter a lista em um conjunto e usar a função de interseção para verificar se há sobreposição:

(apenas uma função de aplicação é usada conforme solicitado :-))

(
    df.assign(s = df.list_of_value.apply(set))
    .pipe(lambda x: pd.DataFrame([[len(e&f)/len(e) for f in x.s] for e in x.s]))
)

    0           1           2           3
0   1.000000    0.666667    1.000000    1.000000
1   0.666667    1.000000    0.666667    0.666667
2   1.000000    0.666667    1.000000    1.000000
3   1.000000    0.666667    1.000000    1.000000
Allen
fonte
0

Eu usaria productpara obter todas as combinações. Então podemos verificar com numpy.isine numpy.mean:

from itertools import product
l = len(df)
new_df = pd.DataFrame(data = np.array(list(map(lambda arr: np.isin(*arr),
                                                product(df['list_of_value'],
                                                        repeat=2))))
                               .mean(axis=1).reshape(l,-1),
                      index = df['id'],
                      columns=df['id'])

id         0         1         2         3
id                                        
0   1.000000  0.666667  1.000000  1.000000
1   0.666667  1.000000  0.666667  0.666667
2   1.000000  0.666667  1.000000  1.000000
3   1.000000  0.666667  1.000000  1.000000

Amostra de tempo

%%timeit
l = len(df)
new_df = pd.DataFrame(data = np.array(list(map(lambda arr: np.isin(*arr),
                                                product(df['list_of_value'],
                                                        repeat=2))))
                               .mean(axis=1).reshape(l,-1),
                      index = df['id'],
                      columns=df['id'])
594 µs ± 5.05 µs per loop (mean ± std. dev. of 7 runs, 1000 loops each)
ansev
fonte
0

Deve ser rápido, considere também a duplicata na lista

... import itertools
... from collections import Counter
... a=df.list_of_value.tolist()
... l=np.array([len(Counter(x[0]) & Counter(x[1]))for x in [*itertools.product(a,a)]]).reshape(len(df),-1)
... out=pd.DataFrame(l/df.list_of_value.str.len().values[:,None],index=df.id,columns=df.id)
... 
out
id         0         1         2         3
id                                        
0   1.000000  0.666667  1.000000  1.000000
1   0.666667  1.000000  0.666667  0.666667
2   1.000000  0.666667  1.000000  1.000000
3   1.000000  0.666667  1.000000  1.000000
YOBEN_S
fonte
0

Sim! Estamos procurando um produto cartesiano aqui, que é fornecido nesta resposta. Isso pode ser obtido sem um loop for ou uma compreensão de lista

Vamos adicionar um novo valor repetido ao nosso quadro de dados dfpara que fique assim:

df['key'] = np.repeat(1, df.shape[0])
df

  list_of_values  key
0      [a, b, c]    1
1      [d, b, c]    1
2      [a, b, c]    1
3      [a, b, c]    1

Em seguida, mesclar-se

merged = pd.merge(df, df, on='key')[['list_of_values_x', 'list_of_values_y']]

É assim que o quadro mesclado se parece:

   list_of_values_x list_of_values_y
0         [a, b, c]        [a, b, c]
1         [a, b, c]        [d, b, c]
2         [a, b, c]        [a, b, c]
3         [a, b, c]        [a, b, c]
4         [d, b, c]        [a, b, c]
5         [d, b, c]        [d, b, c]
6         [d, b, c]        [a, b, c]
7         [d, b, c]        [a, b, c]
8         [a, b, c]        [a, b, c]
9         [a, b, c]        [d, b, c]
10        [a, b, c]        [a, b, c]
11        [a, b, c]        [a, b, c]
12        [a, b, c]        [a, b, c]
13        [a, b, c]        [d, b, c]
14        [a, b, c]        [a, b, c]
15        [a, b, c]        [a, b, c]

Em seguida, aplicamos a função desejada a cada linha usando axis=1

values = merged.apply(lambda x: np.intersect1d(x[0], x[1]).shape[0] / len(x[1]), axis=1)

Remodelando isso para obter valores no formato desejado

values.values.reshape(4, 4)
array([[1.        , 0.66666667, 1.        , 1.        ],
       [0.66666667, 1.        , 0.66666667, 0.66666667],
       [1.        , 0.66666667, 1.        , 1.        ],
       [1.        , 0.66666667, 1.        , 1.        ]])

Espero que isto ajude :)

Pushkar Nimkar
fonte