首页
网站开发
桌面应用
管理软件
微信开发
App开发
嵌入式软件
工具软件
数据采集与分析
其他
首页
>
> 详细
Data留学生编程讲解、辅导analysis程序、SQL语言程序调试 讲解R语言编程|解析C/C++编程
项目预算:
开发周期:
发布时间:
要求地区:
Analyzing 10Gb of Yelp Reviews Data
For this project, you will be tasked with provisioning a Spark Cluster on AWS EMR for loading and running some analysis on Yelp’s Reviews and Businesses dataset (about 10gb) from Kaggle. You will run your analysis via Jupyter Notebook and the expected output artifact is a .ipynb file.
Requirements 2
Artifacts 2
Notebook File 2
PDF File 2
README 3
S3 Bucket 4
Submission 4
Assignment 4
Part I: Installation and Initial Setup 5
Part II: Analyzing Categories 5
Part III: Do Yelp Reviews Skew Negative? 5
Part IV: Should the Elite be Trusted? (Or, some other analysis of your choice) 5
Requirements
This project is very simple: you are to provision a Spark cluster on AWS EMR, connect it to a Jupyter Notebook and then run a series of queries (in python with DataFrame API or Spark SQL) that answer a few simple questions about the Yelp Data available.
In doing so, you are demonstrating your ability to configure and provision infrastructure using the AWS Elastic Map Reduce ecosystem. Also you are demonstrating your understanding of how to leverage transformations and actions (as per the Spark terminology) with PySpark in performing basic data analysis tasks on information sources that are too large to manage in memory.
This project is due TUESDAY APRIL 27TH, MIDNIGHT.
PLEASE READ THE FOLLOWING INSTRUCTIONS CAREFULLY. I will likely be automating some or most of the grading process and therefore your output artifact must match the spec I define below.
Artifacts
You are to submit a zip file with your project work content (as seen below) inside. Expected Zip file structure:
project02
+-- Analysis.ipynb
+-- Analysis.pdf
+-- assets
+-- +-- cluster_configuration.png
+-- +-- notebook_configuration.png
+-- README.md
Note: I’m ok with the images submitted as jpegs as well.
Notebook File
The ipynb file that contains your analysis and the outputs of the code you wrote to arrive at your results. This is very important as this is the sole method of validation that you actually ran an EMR cluster successfully.
You must name your Notebook file Analysis.ipynb. PLEASE PLACE THIS IN YOUR PROJECT ROOT FOLDER.
PDF File
From your EMR notebook, if you download your file as html, you can open it in the browser and save it as PDF. I’d like you to name this file Analysis.pdf and include it in the zip artifact.
README
The README, in markdown, should contain a brief blurb describing the project and the technology leveraged to conduct your analysis. This ought to be brief and informational, in case folks in the future want to recreate your results.
ALSO, your README must contain screenshots of your EMR cluster configuration and Notebook configuration. Here are mine, shared below as reference
Example markdown code:
![cluster_iamge](assets/cluster_configuration.png)
PS: if you wanted to “test” your readme, you can download a readme viewer like this one
Cluster Configuration
Notebook Configuration
S3 Bucket
You must read your Yelp data from S3. In order to do so, you can use my publicly available bucket which contains all the data needed for your analysis. Your Analysis.ipynb file must demonstrate that the data is being read from S3 - this is largely as simple loading your DataFrame like so:
Assignment
The actual analysis is broken into four parts - three which are guided and one that is freeform. I have published a sample github repo demonstrating this project.
Note that the output of the code written is provided as a means to give you structure as you write your analysis. For Parts I, II & III, you must fill in the blanks (implement the code however you want) to get the output provided in the file. (Mainly columns and aggregations, I don't care about the exact rows).
For Parts III and IV, you have more flexibility to take the analysis further however you see fit. Below, I expound a bit more about each part of analysis.
Part I: Installation and Initial Setup
In this portion, you will import the necessary dependencies (pandas and matplotlib, seaborn is optional) and load your dataset as a pyspark dataframe.
Part II: Analyzing Categories
For this part, you will take a stab at denormalizing the categories that are associated with each business (there may be more than one, presented as a string of comma separated identifiers) and then running some basic analysis on the result.
Part III: Do Yelp Reviews Skew Negative?
For this next part, you will attempt to answer the question: are the (written) reviews generally more pessimistic or more optimistic as compared to the overall business rating. There are some required questions you must answer (see the analysis.ipynb file) which is the bare minimum. But, feel free to have fun with it and take your analysis as far as you’d like. Any additional work you do will be counted for up to 5 points of extra credit on your project grade, capped at 105.
Part IV: Should the Elite be Trusted? (Or, some other analysis of your choice)
For this final part you may choose to either answer the question posed or explore the data in some other manner of your own choosing. The only requirements are:
●You must leverage the users dataset provided
●You must have at least one data visualization as part of your analysis
RUBRIC
Overall/Part 1 6
README.md markdown file is available directly in the project02 root folder 1
README contains screenshots of your EMR cluster configuration AND Notebook configuration 1
Analysis.ipynb file and Analysis.pdf are both available directly in the project02 root folder 1
Any necessary packages are loaded in to environment (pandas, matplotlib, seaborn, etc) before any analysis has been started 1
Generally, analysis structure in Analysis.ipynb follows the same structure available here (similar headings and subheadings). 1
Blank fields in the Analysis.ipynb sample file provided are answered. 1
Part 2 8
*business.json dataset is loaded from S3 bucket and saved as Spark DF 1
A Spark DF is derived associating business id with categories. Each business_id is represented multiple times, 1x per category in this DF 3
A Spark DF is derived from the previous DF that represents the number of businesses per category.
(Ok if output is not exactly like the one shown in my Analysis.ipynb). I care more about the table columns and that you are able to rollup counts. 2
Bar chart of “top” categories (from previous DF) is plotted and rendered. (You can use either seaborn or matplotlib) 2
Part 3 8
*review.json dataset is loaded from S3 bucket and saved as Spark DF 1
Spark DF is derived containing business_id col and average stars/business aggregate col from user reviews DF 2
Spark DF from previous row and original business data DF (from Part 2) is joined on business_id field 2
The skew dimension as defined in Analysis.ipynb is computed for each business on the previous DF and histogram is plotted with this data 3
Part 4 8
*user.json dataset is loaded from S3 bucket and saved as Spark DF 1
This DF is joined on either the *review.json or *business.json dataset 4
One dataviz is rendered in analysis 3
软件开发、广告设计客服
QQ:99515681
邮箱:99515681@qq.com
工作时间:8:00-23:00
微信:codinghelp
热点项目
更多
代做ceng0013 design of a pro...
2024-11-13
代做mech4880 refrigeration a...
2024-11-13
代做mcd1350: media studies a...
2024-11-13
代写fint b338f (autumn 2024)...
2024-11-13
代做engd3000 design of tunab...
2024-11-13
代做n1611 financial economet...
2024-11-13
代做econ 2331: economic and ...
2024-11-13
代做cs770/870 assignment 8代...
2024-11-13
代写amath 481/581 autumn qua...
2024-11-13
代做ccc8013 the process of s...
2024-11-13
代写csit040 – modern comput...
2024-11-13
代写econ 2070: introduc2on t...
2024-11-13
代写cct260, project 2 person...
2024-11-13
热点标签
mktg2509
csci 2600
38170
lng302
csse3010
phas3226
77938
arch1162
engn4536/engn6536
acx5903
comp151101
phl245
cse12
comp9312
stat3016/6016
phas0038
comp2140
6qqmb312
xjco3011
rest0005
ematm0051
5qqmn219
lubs5062m
eee8155
cege0100
eap033
artd1109
mat246
etc3430
ecmm462
mis102
inft6800
ddes9903
comp6521
comp9517
comp3331/9331
comp4337
comp6008
comp9414
bu.231.790.81
man00150m
csb352h
math1041
eengm4100
isys1002
08
6057cem
mktg3504
mthm036
mtrx1701
mth3241
eeee3086
cmp-7038b
cmp-7000a
ints4010
econ2151
infs5710
fins5516
fin3309
fins5510
gsoe9340
math2007
math2036
soee5010
mark3088
infs3605
elec9714
comp2271
ma214
comp2211
infs3604
600426
sit254
acct3091
bbt405
msin0116
com107/com113
mark5826
sit120
comp9021
eco2101
eeen40700
cs253
ece3114
ecmm447
chns3000
math377
itd102
comp9444
comp(2041|9044)
econ0060
econ7230
mgt001371
ecs-323
cs6250
mgdi60012
mdia2012
comm221001
comm5000
ma1008
engl642
econ241
com333
math367
mis201
nbs-7041x
meek16104
econ2003
comm1190
mbas902
comp-1027
dpst1091
comp7315
eppd1033
m06
ee3025
msci231
bb113/bbs1063
fc709
comp3425
comp9417
econ42915
cb9101
math1102e
chme0017
fc307
mkt60104
5522usst
litr1-uc6201.200
ee1102
cosc2803
math39512
omp9727
int2067/int5051
bsb151
mgt253
fc021
babs2202
mis2002s
phya21
18-213
cege0012
mdia1002
math38032
mech5125
07
cisc102
mgx3110
cs240
11175
fin3020s
eco3420
ictten622
comp9727
cpt111
de114102d
mgm320h5s
bafi1019
math21112
efim20036
mn-3503
fins5568
110.807
bcpm000028
info6030
bma0092
bcpm0054
math20212
ce335
cs365
cenv6141
ftec5580
math2010
ec3450
comm1170
ecmt1010
csci-ua.0480-003
econ12-200
ib3960
ectb60h3f
cs247—assignment
tk3163
ics3u
ib3j80
comp20008
comp9334
eppd1063
acct2343
cct109
isys1055/3412
math350-real
math2014
eec180
stat141b
econ2101
msinm014/msing014/msing014b
fit2004
comp643
bu1002
cm2030
联系我们
- QQ: 9951568
© 2021
www.rj363.com
软件定制开发网!