पायथन न्यूज बिटकॉइन मूल्य भविष्यवाणी

कार्य

• पायथन 2.6+ या 3.1+ सिस्टम पर स्थापित होना चाहिए
• पांडा , स्केलेर और ओपनब्लेंडर (पाइप का उपयोग करके) स्थापित करें

$ pip install pandas OpenBlender scikit-learn

चरण 1. बिटकॉइन डेटा प्राप्त करें

import OpenBlender
import pandas as pd
import json

# It only contains the id, we'll add more parameters later.
parameters = { 
 'id_dataset':'5d4c3af79516290b01c83f51'
}

parameters = {     
   'token':'your_token',
   'id_dataset':'5d4c3af79516290b01c83f51'
}

# This function pulls the data and orders by timestamp
def pullObservationsToDF(parameters):
    action = 'API_getObservationsFromDataset'
    df = pd.read_json(json.dumps(OpenBlender.call(action,parameters)['sample']), convert_dates=False,convert_axes=False) .sort_values('timestamp', ascending=False)
    df.reset_index(drop=True, inplace=True)
    return df
df = pullObservationsToDF(parameters)

चरण 2. डेटा तैयारी

parameters = {
   'token':'your_token',   
   'id_dataset':'5d4c3af79516290b01c83f51',
   'target_threshold':{'feature':'change', 'success_thr_over': 0}
}

df = pullObservationsToDF(parameters)
df.head() 

parameters = { 
   'token':'your_token',
   'id_dataset':'5d4c3af79516290b01c83f51',
   'target_threshold':{'feature':'change','success_thr_over' : 0},
   'lag_target_feature':{'feature':'change_over_0', 'periods' : 1}
}
df = pullObservationsToDF(parameters)
df.head()

target_variable = 'TARGET_change_over_0'
df = df.dropna()
df.corr()[target_variable].sort_values()

चरण 3. व्यापार समाचार डेटा प्राप्त करें

action = 'API_createTextVectorizer'
vectorizer_parameters = {
    'token' : 'your_token',
    'name' : 'Fox Business TextVectorizer',
    'sources':[{'id_dataset' : '5d571f9e9516293a12ad4f6d',
                'features' : ['title']}],
    'ngram_range' : {'min' : 1, 'max' : 2},
    'language' : 'en',
    'remove_stop_words' : 'on',
    'min_count_limit' : 2
}

• नाम : चलो इसे 'फॉक्स बिजनेस टेक्स्टवेक्टर' कहते हैं ;
• लंगर : डेटासेट की आईडी और उन विशेषताओं का नाम, जिन्हें हमें स्रोत के रूप में उपयोग करने की आवश्यकता होगी (हमारे मामले में, केवल 'शीर्षक' कॉलम );
• ngram_range : टोकन के लिए शब्दों के एक सेट की न्यूनतम और अधिकतम लंबाई;
• भाषा : अंग्रेजी
• remove_stop_words : स्रोत से रोक शब्दों को हटाने के लिए;
• min_count_limit : दोहराव की न्यूनतम संख्या जिसे टोकन माना जाना चाहिए (एकल घटनाएं शायद ही कभी उपयोगी होती हैं)।

res = OpenBlender.call(action, vectorizer_parameters)
res

{  
    'message' : 'TextVectorizer created successfully.'
    'id_textVectorizer' : '5dc1a404951629331f6359dd',
    'num_ngrams': 4270
}

चरण 4. बिटकॉइन डेटासेट के साथ संगत समाचार सारांश

parameters = { 
   'token':'your_token',  
   'id_dataset':'5d4c3af79516290b01c83f51',
   'target_threshold' : {'feature':'change','success_thr_over':0},
   'lag_target_feature' : {'feature':'change_over_0', 'periods':1},
   'blends':[{'id_blend':'5dc1a404951629331f6359dd',
               'blend_type' : 'text_ts',
               'restriction' : 'predictive', 
               'specifications':{'time_interval_size' : 3600*12 }}]
}

• id_blend : हमारे textVectorizer की आईडी;
• ब्लेंड_टाइप : 'text_ts' ताकि पायथन यह समझ सके कि यह टेक्स्ट और टाइमस्टैम्प का मिश्रण है;
• प्रतिबंध : 'प्रेडिक्टिव' , ताकि भविष्य में सभी टिप्पणियों के साथ समाचार का "मिश्रण" न हो, लेकिन केवल उन लोगों के साथ जो निर्दिष्ट समय से पहले प्रकाशित किए गए थे।
• मिश्रण_क्लास : 'निकटतम_संरक्षण' , ताकि केवल निकटतम अवलोकन "मिश्रित" हों;
• विनिर्देशों : अवलोकन के हस्तांतरण के लिए बीता समय की अधिकतम संभव राशि, इस मामले में 12 घंटे (3600 * 12)। इसका मतलब है कि पिछले 12 घंटों की खबरों के आधार पर बिटकॉइन की कीमत के हर अवलोकन की भविष्यवाणी की जाएगी।

parameters = { 
   'token':'your_token',
   'id_dataset':'5d4c3af79516290b01c83f51',
   'target_threshold' : {'feature':'change','success_thr_over':0},
   'lag_target_feature' : {'feature':'change_over_0', 'periods':1},
   'blends':[{'id_blend':'5dc1a404951629331f6359dd',
               'blend_type' : 'text_ts',
               'restriction' : 'predictive',
               'blend_class' : 'closest_observation', 
               'specifications':{'time_interval_size' : 3600*12 }}],
   'date_filter':{'start_date':'2019-08-20T16:59:35.825Z',
                   'end_date':'2019-11-04T17:59:35.825Z'},
   'drop_non_numeric' : 1
}

df = pullObservationsToDF(parameters)
print(df.shape)
df.head()

चरण 5. भविष्यवाणी लक्ष्य के लिए एमएल लागू करें

X = df.loc[:, df.columns != target_variable].values
y = df.loc[:,[target_variable]].values
div = int(round(len(X) * 0.29))
# We take the first observations as test and the last as train because the dataset is ordered by timestamp descending.
X_test = X[:div]
y_test = y[:div]
print(X_test.shape)
print(y_test.shape)
X_train = X[div:]
y_train = y[div:]
print(X_train.shape)
print(y_train.shape)

from sklearn.ensemble import RandomForestRegressor
from sklearn.metrics import mean_squared_error
from sklearn.metrics import accuracy_score
from sklearn.metrics import roc_auc_score
from sklearn import metrics

rf = RandomForestRegressor(n_estimators = 1000)
rf.fit(X_train, y_train)
y_pred = rf.predict(X_test)

df_res = pd.DataFrame({'y_test':y_test[:,0], 'y_pred':y_pred})
df_res.head()

threshold = 0.5
preds = [1 if val > threshold else 0 for val in df_res['y_pred']]

print(roc_auc_score(preds, df_res['y_test']))
print(metrics.confusion_matrix(preds, df_res['y_test']))
print(accuracy_score(preds, df_res['y_test']))

• 9 बार हमने गिरावट की भविष्यवाणी की, और कीमत घट गई (दाएं);
• 5 बार हमने कमी की भविष्यवाणी की, और मूल्य में वृद्धि हुई (गलत तरीके से);
• 1 बार हमने वृद्धि की भविष्यवाणी की, लेकिन कीमत गलत तरीके से घट गई);
• 2 बार हमने वृद्धि की भविष्यवाणी की, और कीमत बढ़ गई (सच)।