@@ -412,6 +412,53 @@ def DataReader(name, data_source=None, start=None, end=None,
412
412
retry_count = retry_count , pause = pause ,
413
413
session = session , interval = 'd' ).read ()
414
414
415
+ elif data_source == "av-forex" :
416
+ return AVForexReader (symbols = name , retry_count = retry_count ,
417
+ pause = pause , session = session ,
418
+ api_key = access_key ).read ()
419
+
420
+ elif data_source == "av-daily" :
421
+ return AVTimeSeriesReader (symbols = name ,
422
+ function = "TIME_SERIES_DAILY" , start = start ,
423
+ end = end , retry_count = retry_count ,
424
+ pause = pause , session = session ,
425
+ api_key = access_key ).read ()
426
+
427
+ elif data_source == "av-daily-adjusted" :
428
+ return AVTimeSeriesReader (symbols = name ,
429
+ function = "TIME_SERIES_DAILY_ADJUSTED" ,
430
+ start = start , end = end ,
431
+ retry_count = retry_count , pause = pause ,
432
+ session = session , api_key = access_key ).read ()
433
+
434
+ elif data_source == "av-weekly" :
435
+ return AVTimeSeriesReader (symbols = name ,
436
+ function = "TIME_SERIES_WEEKLY" , start = start ,
437
+ end = end , retry_count = retry_count ,
438
+ pause = pause , session = session ,
439
+ api_key = access_key ).read ()
440
+
441
+ elif data_source == "av-weekly-adjusted" :
442
+ return AVTimeSeriesReader (symbols = name ,
443
+ function = "TIME_SERIES_WEEKLY_ADJUSTED" ,
444
+ start = start , end = end ,
445
+ retry_count = retry_count , pause = pause ,
446
+ session = session , api_key = access_key ).read ()
447
+
448
+ elif data_source == "av-monthly" :
449
+ return AVTimeSeriesReader (symbols = name ,
450
+ function = "TIME_SERIES_MONTHLY" , start = start ,
451
+ end = end , retry_count = retry_count ,
452
+ pause = pause , session = session ,
453
+ api_key = access_key ).read ()
454
+
455
+ elif data_source == "av-monthly-adjusted" :
456
+ return AVTimeSeriesReader (symbols = name ,
457
+ function = "TIME_SERIES_MONTHLY_ADJUSTED" ,
458
+ start = start , end = end ,
459
+ retry_count = retry_count , pause = pause ,
460
+ session = session , api_key = access_key ).read ()
461
+
415
462
else :
416
463
msg = "data_source=%r is not implemented" % data_source
417
464
raise NotImplementedError (msg )
0 commit comments