Compare commits
31 Commits
c10c88657b
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
716b0bde1d | ||
|
|
5a9e08345c | ||
|
|
ca0386ead9 | ||
|
|
0d79da2555 | ||
|
|
47160a20ed | ||
|
|
38c32701e7 | ||
|
|
5cd365a113 | ||
|
|
2a270ee783 | ||
|
|
7403887e37 | ||
|
|
91c54726e1 | ||
|
|
bb2e6a7c2d | ||
|
|
2b95643f3d | ||
|
|
6fd51ad286 | ||
|
|
691fb7b40f | ||
|
|
6ee324d52e | ||
|
|
bc42fc6a81 | ||
|
|
901880e71b | ||
|
|
e3335bb262 | ||
|
|
57653a38a2 | ||
|
|
1258e2ef97 | ||
|
|
4b215ab2e1 | ||
|
|
73638d8915 | ||
|
|
cbc841b364 | ||
|
|
b6e30e6a53 | ||
|
|
3324d9888a | ||
|
|
77888e9bd2 | ||
|
|
6f442db00d | ||
|
|
9811487087 | ||
|
|
8971d6a55b | ||
|
|
4c7205f9ac | ||
|
|
c472f198bd |
2
.gitignore
vendored
@@ -1 +1,3 @@
|
||||
Aigrind/data
|
||||
Aigrind/.ipynb_checkpoints
|
||||
egeland/.ipynb_checkpoints
|
||||
|
||||
1573
Aigrind/Analisys.ipynb
Normal file
@@ -32,4 +32,78 @@
|
||||
кампаний на ранних стадиях (не дожидаясь достижения срока окупаемости), можете
|
||||
их описать с обоснованием и предоставить расчет - будет большим плюсом.
|
||||
|
||||
## Отчет
|
||||
|
||||
### Оптимальный срок оценки окупаемости рекламных кампаний
|
||||
|
||||

|
||||
|
||||
|
||||
| Рекламная сеть | Тип кампании | Целевая аудитория | Time, (months) |
|
||||
|:--------------------------:|:--------------:|:---------------------:|:----------------:|
|
||||
| Media_source_1 | install | Brazil | 0.330097 |
|
||||
| Media_source_1 | purchase | Brazil | 0.850925 |
|
||||
| Media_source_1 | install | Russia | 0.319666 |
|
||||
| Media_source_1 | purchase | Russia | 0.724876 |
|
||||
| Media_source_1 | install | Ukrane | 0.917769 |
|
||||
| Media_source_1 | purchase | Ukrane | 0.343303 |
|
||||
| Media_source_2 | install | Brazil | 5.33726 |
|
||||
| Media_source_2 | install | English_speaking | 3.90023 |
|
||||
|
||||
### Наиболее успешные кейсы
|
||||
|
||||
#### Рекламные кампании
|
||||
|
||||

|
||||
|
||||
|
||||
| Рекламная сеть | Тип кампании | Целевая аудитория | Time, (months) |
|
||||
|:--------------------------:|:--------------:|:---------------------:|:----------------:|
|
||||
| Media_source_1 | install | Russia | 0.319666 |
|
||||
| Media_source_1 | install | Brazil | 0.330097 |
|
||||
| Media_source_1 | purchase | Ukrane | 0.343303 |
|
||||
| Media_source_1 | purchase | Russia | 0.724876 |
|
||||
| Media_source_1 | purchase | Brazil | 0.850925 |
|
||||
| Media_source_1 | install | Ukrane | 0.917769 |
|
||||
| Media_source_2 | install | English_speaking | 3.90023 |
|
||||
| Media_source_2 | install | Brazil | 5.33726 |
|
||||
|
||||
#### Тип рекламных кампаний
|
||||
|
||||

|
||||
|
||||
#### Рекламная сеть
|
||||
|
||||

|
||||
|
||||
### Накопительный ARPU успешных рекламных кампаний
|
||||
|
||||

|
||||
|
||||
|
||||
| days | RUS_MS1_purchase | UKR_MS1_purchase | BRA_MS1_purchase |
|
||||
|:-------:|:------------------:|:------------------:|:------------------:|
|
||||
| 7 days | 0.570234 | 0.644273 | 4.71347 |
|
||||
| 14 days | 0.759229 | 0.644273 | 4.71347 |
|
||||
| 30 days | 1.31604 | 1.82198 | 4.73251 |
|
||||
|
||||
### Фактический CPI
|
||||
|
||||

|
||||
|
||||
|
||||
| Рекламная сеть | Тип кампании | Целевая аудитория | CPI |
|
||||
|:--------------------------:|:--------------:|:---------------------:|:----------:|
|
||||
| Media_source_1 | install | Brazil | 0.00864771 |
|
||||
| Media_source_1 | install | Ukrane | 0.0146436 |
|
||||
| Media_source_1 | install | Russia | 0.0194719 |
|
||||
| Media_source_2 | install | English_speaking | 0.245577 |
|
||||
| Media_source_1 | purchase | Brazil | 0.350018 |
|
||||
| Media_source_1 | purchase | Russia | 0.390114 |
|
||||
| Media_source_2 | install | Brazil | 0.533882 |
|
||||
| Media_source_1 | purchase | Ukrane | 1.33896 |
|
||||
|
||||
#### Отклонения от бюджета
|
||||
|
||||

|
||||
|
||||
|
||||
254
Aigrind/environment.yaml
Normal file
@@ -0,0 +1,254 @@
|
||||
name: aigrind
|
||||
channels:
|
||||
- conda-forge
|
||||
dependencies:
|
||||
- _libgcc_mutex=0.1=conda_forge
|
||||
- _openmp_mutex=4.5=2_gnu
|
||||
- alsa-lib=1.2.13=hb9d3cd8_0
|
||||
- anyio=4.6.2.post1=pyhd8ed1ab_0
|
||||
- argon2-cffi=23.1.0=pyhd8ed1ab_0
|
||||
- argon2-cffi-bindings=21.2.0=py313h536fd9c_5
|
||||
- arrow=1.3.0=pyhd8ed1ab_0
|
||||
- asttokens=2.4.1=pyhd8ed1ab_0
|
||||
- attrs=24.2.0=pyh71513ae_0
|
||||
- autopep8=2.3.1=pyhd8ed1ab_0
|
||||
- beautifulsoup4=4.12.3=pyha770c72_0
|
||||
- bleach=6.2.0=pyhd8ed1ab_0
|
||||
- brotli=1.1.0=hb9d3cd8_2
|
||||
- brotli-bin=1.1.0=hb9d3cd8_2
|
||||
- bzip2=1.0.8=h4bc722e_7
|
||||
- ca-certificates=2024.8.30=hbcca054_0
|
||||
- cached-property=1.5.2=hd8ed1ab_1
|
||||
- cached_property=1.5.2=pyha770c72_1
|
||||
- cairo=1.18.0=hebfffa5_3
|
||||
- certifi=2024.8.30=pyhd8ed1ab_0
|
||||
- cffi=1.17.1=py313hfab6e84_0
|
||||
- colorama=0.4.6=pyhd8ed1ab_0
|
||||
- comm=0.2.2=pyhd8ed1ab_0
|
||||
- contourpy=1.3.1=py313h33d0bda_0
|
||||
- cycler=0.12.1=pyhd8ed1ab_0
|
||||
- cyrus-sasl=2.1.27=h54b06d7_7
|
||||
- dbus=1.13.6=h5008d03_3
|
||||
- debugpy=1.8.9=py313h46c70d0_0
|
||||
- decorator=5.1.1=pyhd8ed1ab_0
|
||||
- defusedxml=0.7.1=pyhd8ed1ab_0
|
||||
- double-conversion=3.3.0=h59595ed_0
|
||||
- entrypoints=0.4=pyhd8ed1ab_0
|
||||
- et_xmlfile=2.0.0=pyhd8ed1ab_0
|
||||
- exceptiongroup=1.2.2=pyhd8ed1ab_0
|
||||
- executing=2.1.0=pyhd8ed1ab_0
|
||||
- expat=2.6.4=h5888daf_0
|
||||
- font-ttf-dejavu-sans-mono=2.37=hab24e00_0
|
||||
- font-ttf-inconsolata=3.000=h77eed37_0
|
||||
- font-ttf-source-code-pro=2.038=h77eed37_0
|
||||
- font-ttf-ubuntu=0.83=h77eed37_3
|
||||
- fontconfig=2.15.0=h7e30c49_1
|
||||
- fonts-conda-ecosystem=1=0
|
||||
- fonts-conda-forge=1=0
|
||||
- fonttools=4.55.0=py313h8060acc_0
|
||||
- fqdn=1.5.1=pyhd8ed1ab_0
|
||||
- freetype=2.12.1=h267a509_2
|
||||
- graphite2=1.3.13=h59595ed_1003
|
||||
- harfbuzz=9.0.0=hda332d3_1
|
||||
- hugo=0.139.2=h5888daf_0
|
||||
- icu=75.1=he02047a_0
|
||||
- idna=3.10=pyhd8ed1ab_0
|
||||
- importlib_resources=6.4.5=pyhd8ed1ab_0
|
||||
- ipykernel=6.29.5=pyh3099207_0
|
||||
- ipython=8.29.0=pyh707e725_0
|
||||
- ipython_genutils=0.2.0=pyhd8ed1ab_1
|
||||
- isoduration=20.11.0=pyhd8ed1ab_0
|
||||
- jedi=0.19.2=pyhff2d567_0
|
||||
- jinja2=3.1.4=pyhd8ed1ab_0
|
||||
- jsonpointer=3.0.0=py313h78bf25f_1
|
||||
- jsonschema=4.23.0=pyhd8ed1ab_0
|
||||
- jsonschema-specifications=2024.10.1=pyhd8ed1ab_0
|
||||
- jsonschema-with-format-nongpl=4.23.0=hd8ed1ab_0
|
||||
- jupyter_client=7.4.9=pyhd8ed1ab_0
|
||||
- jupyter_contrib_core=0.4.0=pyhd8ed1ab_0
|
||||
- jupyter_contrib_nbextensions=0.7.0=pyhd8ed1ab_0
|
||||
- jupyter_core=5.7.2=pyh31011fe_1
|
||||
- jupyter_events=0.10.0=pyhd8ed1ab_0
|
||||
- jupyter_highlight_selected_word=0.2.0=pyhd8ed1ab_1006
|
||||
- jupyter_latex_envs=1.4.6=pyhd8ed1ab_1002
|
||||
- jupyter_nbextensions_configurator=0.6.1=pyhd8ed1ab_0
|
||||
- jupyter_server=2.14.2=pyhd8ed1ab_0
|
||||
- jupyter_server_terminals=0.5.3=pyhd8ed1ab_0
|
||||
- jupyterlab_pygments=0.3.0=pyhd8ed1ab_1
|
||||
- keyutils=1.6.1=h166bdaf_0
|
||||
- kiwisolver=1.4.7=py313h33d0bda_0
|
||||
- krb5=1.21.3=h659f571_0
|
||||
- lcms2=2.16=hb7c19ff_0
|
||||
- ld_impl_linux-64=2.43=h712a8e2_2
|
||||
- lerc=4.0.0=h27087fc_0
|
||||
- libblas=3.9.0=25_linux64_openblas
|
||||
- libbrotlicommon=1.1.0=hb9d3cd8_2
|
||||
- libbrotlidec=1.1.0=hb9d3cd8_2
|
||||
- libbrotlienc=1.1.0=hb9d3cd8_2
|
||||
- libcblas=3.9.0=25_linux64_openblas
|
||||
- libclang-cpp19.1=19.1.4=default_hb5137d0_0
|
||||
- libclang13=19.1.4=default_h9c6a7e4_0
|
||||
- libcups=2.3.3=h4637d8d_4
|
||||
- libdeflate=1.22=hb9d3cd8_0
|
||||
- libdrm=2.4.123=hb9d3cd8_0
|
||||
- libedit=3.1.20191231=he28a2e2_2
|
||||
- libegl=1.7.0=ha4b6fd6_2
|
||||
- libexpat=2.6.4=h5888daf_0
|
||||
- libffi=3.4.2=h7f98852_5
|
||||
- libgcc=14.2.0=h77fa898_1
|
||||
- libgcc-ng=14.2.0=h69a702a_1
|
||||
- libgfortran=14.2.0=h69a702a_1
|
||||
- libgfortran5=14.2.0=hd5240d6_1
|
||||
- libgl=1.7.0=ha4b6fd6_2
|
||||
- libglib=2.82.2=h2ff4ddf_0
|
||||
- libglvnd=1.7.0=ha4b6fd6_2
|
||||
- libglx=1.7.0=ha4b6fd6_2
|
||||
- libgomp=14.2.0=h77fa898_1
|
||||
- libiconv=1.17=hd590300_2
|
||||
- libjpeg-turbo=3.0.0=hd590300_1
|
||||
- liblapack=3.9.0=25_linux64_openblas
|
||||
- libllvm19=19.1.4=ha7bfdaf_0
|
||||
- libmpdec=4.0.0=h4bc722e_0
|
||||
- libntlm=1.4=h7f98852_1002
|
||||
- libopenblas=0.3.28=pthreads_h94d23a6_1
|
||||
- libopengl=1.7.0=ha4b6fd6_2
|
||||
- libpciaccess=0.18=hd590300_0
|
||||
- libpng=1.6.44=hadc24fc_0
|
||||
- libpq=17.2=h04577a9_0
|
||||
- libsodium=1.0.20=h4ab18f5_0
|
||||
- libsqlite=3.47.0=hadc24fc_1
|
||||
- libstdcxx=14.2.0=hc0a3c3a_1
|
||||
- libstdcxx-ng=14.2.0=h4852527_1
|
||||
- libtiff=4.7.0=he137b08_1
|
||||
- libuuid=2.38.1=h0b41bf4_0
|
||||
- libwebp-base=1.4.0=hd590300_0
|
||||
- libxcb=1.17.0=h8a09558_0
|
||||
- libxkbcommon=1.7.0=h2c5496b_1
|
||||
- libxml2=2.13.5=hb346dea_0
|
||||
- libxslt=1.1.39=h76b75d6_0
|
||||
- libzlib=1.3.1=hb9d3cd8_2
|
||||
- lxml=5.3.0=py313h6eb7059_2
|
||||
- markupsafe=3.0.2=py313h8060acc_0
|
||||
- matplotlib=3.9.2=py313h78bf25f_2
|
||||
- matplotlib-base=3.9.2=py313h129903b_2
|
||||
- matplotlib-inline=0.1.7=pyhd8ed1ab_0
|
||||
- mistune=3.0.2=pyhd8ed1ab_0
|
||||
- munkres=1.1.4=pyh9f0ad1d_0
|
||||
- mysql-common=9.0.1=h266115a_2
|
||||
- mysql-libs=9.0.1=he0572af_2
|
||||
- nbclassic=1.1.0=pyhd8ed1ab_0
|
||||
- nbclient=0.10.0=pyhd8ed1ab_0
|
||||
- nbconvert=7.16.4=hd8ed1ab_1
|
||||
- nbconvert-core=7.16.4=pyhd8ed1ab_1
|
||||
- nbconvert-pandoc=7.16.4=hd8ed1ab_1
|
||||
- nbformat=5.10.4=pyhd8ed1ab_0
|
||||
- ncurses=6.5=he02047a_1
|
||||
- nest-asyncio=1.6.0=pyhd8ed1ab_0
|
||||
- notebook=6.5.7=pyha770c72_0
|
||||
- notebook-shim=0.2.4=pyhd8ed1ab_0
|
||||
- numpy=2.1.3=py313h4bf6692_0
|
||||
- openjpeg=2.5.2=h488ebb8_0
|
||||
- openldap=2.6.8=hedd0468_0
|
||||
- openpyxl=3.1.5=py313h9c9eb82_1
|
||||
- openssl=3.4.0=hb9d3cd8_0
|
||||
- overrides=7.7.0=pyhd8ed1ab_0
|
||||
- packaging=24.2=pyhff2d567_1
|
||||
- pandas=2.2.3=py313ha87cce1_1
|
||||
- pandoc=3.5=ha770c72_0
|
||||
- pandocfilters=1.5.0=pyhd8ed1ab_0
|
||||
- parso=0.8.4=pyhd8ed1ab_0
|
||||
- patsy=1.0.1=pyhff2d567_0
|
||||
- pcre2=10.44=hba22ea6_2
|
||||
- pexpect=4.9.0=pyhd8ed1ab_0
|
||||
- pickleshare=0.7.5=py_1003
|
||||
- pillow=11.0.0=py313h2d7ed13_0
|
||||
- pip=24.3.1=pyh145f28c_0
|
||||
- pixman=0.43.2=h59595ed_0
|
||||
- pkgutil-resolve-name=1.3.10=pyhd8ed1ab_1
|
||||
- platformdirs=4.3.6=pyhd8ed1ab_0
|
||||
- prometheus_client=0.21.0=pyhd8ed1ab_0
|
||||
- prompt-toolkit=3.0.48=pyha770c72_0
|
||||
- psutil=6.1.0=py313h536fd9c_0
|
||||
- pthread-stubs=0.4=hb9d3cd8_1002
|
||||
- ptyprocess=0.7.0=pyhd3deb0d_0
|
||||
- pure_eval=0.2.3=pyhd8ed1ab_0
|
||||
- pycodestyle=2.12.1=pyhd8ed1ab_0
|
||||
- pycparser=2.22=pyhd8ed1ab_0
|
||||
- pygments=2.18.0=pyhd8ed1ab_0
|
||||
- pyparsing=3.2.0=pyhd8ed1ab_1
|
||||
- pyside6=6.8.0.2=py313h5f61773_0
|
||||
- python=3.13.0=h9ebbce0_100_cp313
|
||||
- python-dateutil=2.9.0.post0=pyhff2d567_0
|
||||
- python-fastjsonschema=2.20.0=pyhd8ed1ab_0
|
||||
- python-json-logger=2.0.7=pyhd8ed1ab_0
|
||||
- python-tzdata=2024.2=pyhd8ed1ab_0
|
||||
- python_abi=3.13=5_cp313
|
||||
- pytz=2024.1=pyhd8ed1ab_0
|
||||
- pyyaml=6.0.2=py313h536fd9c_1
|
||||
- pyzmq=26.2.0=py313h8e95178_3
|
||||
- qhull=2020.2=h434a139_5
|
||||
- qt6-main=6.8.0=h6e8976b_0
|
||||
- readline=8.2=h8228510_1
|
||||
- referencing=0.35.1=pyhd8ed1ab_0
|
||||
- rfc3339-validator=0.1.4=pyhd8ed1ab_0
|
||||
- rfc3986-validator=0.1.1=pyh9f0ad1d_0
|
||||
- rpds-py=0.21.0=py313h920b4c0_0
|
||||
- scipy=1.14.1=py313h27c5614_1
|
||||
- seaborn=0.13.2=hd8ed1ab_2
|
||||
- seaborn-base=0.13.2=pyhd8ed1ab_2
|
||||
- send2trash=1.8.3=pyh0d859eb_0
|
||||
- setuptools=75.6.0=pyhff2d567_0
|
||||
- six=1.16.0=pyh6c4a22f_0
|
||||
- sniffio=1.3.1=pyhd8ed1ab_0
|
||||
- soupsieve=2.5=pyhd8ed1ab_1
|
||||
- stack_data=0.6.2=pyhd8ed1ab_0
|
||||
- statsmodels=0.14.4=py313ha014f3b_0
|
||||
- tabulate=0.9.0=pyhd8ed1ab_1
|
||||
- terminado=0.18.1=pyh0d859eb_0
|
||||
- tinycss2=1.4.0=pyhd8ed1ab_0
|
||||
- tk=8.6.13=noxft_h4845f30_101
|
||||
- tomli=2.1.0=pyhff2d567_0
|
||||
- tornado=6.4.1=py313h536fd9c_1
|
||||
- tqdm=4.67.0=pyhd8ed1ab_0
|
||||
- traitlets=5.14.3=pyhd8ed1ab_0
|
||||
- types-python-dateutil=2.9.0.20241003=pyhff2d567_0
|
||||
- typing-extensions=4.12.2=hd8ed1ab_0
|
||||
- typing_extensions=4.12.2=pyha770c72_0
|
||||
- typing_utils=0.1.0=pyhd8ed1ab_0
|
||||
- tzdata=2024b=hc8b5060_0
|
||||
- uri-template=1.3.0=pyhd8ed1ab_0
|
||||
- wayland=1.23.1=h3e06ad9_0
|
||||
- wcwidth=0.2.13=pyhd8ed1ab_0
|
||||
- webcolors=24.8.0=pyhd8ed1ab_0
|
||||
- webencodings=0.5.1=pyhd8ed1ab_2
|
||||
- websocket-client=1.8.0=pyhd8ed1ab_0
|
||||
- xcb-util=0.4.1=hb711507_2
|
||||
- xcb-util-cursor=0.1.5=hb9d3cd8_0
|
||||
- xcb-util-image=0.4.0=hb711507_2
|
||||
- xcb-util-keysyms=0.4.1=hb711507_0
|
||||
- xcb-util-renderutil=0.3.10=hb711507_0
|
||||
- xcb-util-wm=0.4.2=hb711507_0
|
||||
- xkeyboard-config=2.43=hb9d3cd8_0
|
||||
- xorg-libice=1.1.1=hb9d3cd8_1
|
||||
- xorg-libsm=1.2.4=he73a12e_1
|
||||
- xorg-libx11=1.8.10=h4f16b4b_0
|
||||
- xorg-libxau=1.0.11=hb9d3cd8_1
|
||||
- xorg-libxcomposite=0.4.6=hb9d3cd8_2
|
||||
- xorg-libxcursor=1.2.3=hb9d3cd8_0
|
||||
- xorg-libxdamage=1.1.6=hb9d3cd8_0
|
||||
- xorg-libxdmcp=1.1.5=hb9d3cd8_0
|
||||
- xorg-libxext=1.3.6=hb9d3cd8_0
|
||||
- xorg-libxfixes=6.0.1=hb9d3cd8_0
|
||||
- xorg-libxi=1.8.2=hb9d3cd8_0
|
||||
- xorg-libxrandr=1.5.4=hb9d3cd8_0
|
||||
- xorg-libxrender=0.9.11=hb9d3cd8_1
|
||||
- xorg-libxtst=1.2.5=hb9d3cd8_3
|
||||
- xorg-libxxf86vm=1.1.5=hb9d3cd8_4
|
||||
- xorg-xorgproto=2024.1=hb9d3cd8_1
|
||||
- xz=5.2.6=h166bdaf_0
|
||||
- yaml=0.2.5=h7f98852_2
|
||||
- zeromq=4.3.5=h3b0a872_7
|
||||
- zipp=3.21.0=pyhd8ed1ab_0
|
||||
- zlib=1.3.1=hb9d3cd8_2
|
||||
- zstd=1.5.6=ha6fb4c9_0
|
||||
|
||||
BIN
Aigrind/pics/arpu.png
Normal file
|
After Width: | Height: | Size: 81 KiB |
BIN
Aigrind/pics/cpi.deviation.png
Normal file
|
After Width: | Height: | Size: 85 KiB |
BIN
Aigrind/pics/cpi.sorted.png
Normal file
|
After Width: | Height: | Size: 74 KiB |
BIN
Aigrind/pics/payback-period.ct.png
Normal file
|
After Width: | Height: | Size: 34 KiB |
BIN
Aigrind/pics/payback-period.ms.png
Normal file
|
After Width: | Height: | Size: 36 KiB |
BIN
Aigrind/pics/payback-period.png
Normal file
|
After Width: | Height: | Size: 86 KiB |
BIN
Aigrind/pics/payback-period.sorted.png
Normal file
|
After Width: | Height: | Size: 85 KiB |
9124
Aigrind/report.html
Normal file
4
Aigrind/tables/arpu.csv
Normal file
@@ -0,0 +1,4 @@
|
||||
,RUS_MS1_purchase,UKR_MS1_purchase,BRA_MS1_purchase,days
|
||||
6,0.5702344287581702,0.6442734645479453,4.7134661254054055,7 days
|
||||
13,0.7592291686274512,0.6442734645479453,4.7134661254054055,14 days
|
||||
29,1.3160387200000006,1.8219817494794524,4.732509507027027,30 days
|
||||
|
5
Aigrind/tables/arpu.md
Normal file
@@ -0,0 +1,5 @@
|
||||
| | RUS_MS1_purchase | UKR_MS1_purchase | BRA_MS1_purchase | days |
|
||||
|---:|-------------------:|-------------------:|-------------------:|:--------|
|
||||
| 6 | 0.570234 | 0.644273 | 4.71347 | 7 days |
|
||||
| 13 | 0.759229 | 0.644273 | 4.71347 | 14 days |
|
||||
| 29 | 1.31604 | 1.82198 | 4.73251 | 30 days |
|
||||
9
Aigrind/tables/cpi.sorted.csv
Normal file
@@ -0,0 +1,9 @@
|
||||
Media Source,Campaign type,Target,CPI
|
||||
Media_source_1,install,Brazil,0.008647705461525039
|
||||
Media_source_1,install,Ukrane,0.01464359351988218
|
||||
Media_source_1,install,Russia,0.019471895011463358
|
||||
Media_source_2,install,English_speaking,0.24557739557739558
|
||||
Media_source_1,purchase,Brazil,0.350017559262511
|
||||
Media_source_1,purchase,Russia,0.39011385199240983
|
||||
Media_source_2,install,Brazil,0.5338815789473684
|
||||
Media_source_1,purchase,Ukrane,1.3389615384615385
|
||||
|
10
Aigrind/tables/cpi.sorted.md
Normal file
@@ -0,0 +1,10 @@
|
||||
| | CPI |
|
||||
|:--------------------------------------------------|-----------:|
|
||||
| ('Media_source_1', 'install', 'Brazil') | 0.00864771 |
|
||||
| ('Media_source_1', 'install', 'Ukrane') | 0.0146436 |
|
||||
| ('Media_source_1', 'install', 'Russia') | 0.0194719 |
|
||||
| ('Media_source_2', 'install', 'English_speaking') | 0.245577 |
|
||||
| ('Media_source_1', 'purchase', 'Brazil') | 0.350018 |
|
||||
| ('Media_source_1', 'purchase', 'Russia') | 0.390114 |
|
||||
| ('Media_source_2', 'install', 'Brazil') | 0.533882 |
|
||||
| ('Media_source_1', 'purchase', 'Ukrane') | 1.33896 |
|
||||
9
Aigrind/tables/payback-period.csv
Normal file
@@ -0,0 +1,9 @@
|
||||
Media Source,Campaign type,Target,"Time, (months)"
|
||||
Media_source_1,install,Brazil,0.3300967979179157
|
||||
Media_source_1,purchase,Brazil,0.8509252137211926
|
||||
Media_source_1,install,Russia,0.3196661081626587
|
||||
Media_source_1,purchase,Russia,0.724875510844611
|
||||
Media_source_1,install,Ukrane,0.9177685774719259
|
||||
Media_source_1,purchase,Ukrane,0.3433033484234126
|
||||
Media_source_2,install,Brazil,5.337257113760678
|
||||
Media_source_2,install,English_speaking,3.9002341108208425
|
||||
|
10
Aigrind/tables/payback-period.md
Normal file
@@ -0,0 +1,10 @@
|
||||
| | Time, (months) |
|
||||
|:--------------------------------------------------|-----------------:|
|
||||
| ('Media_source_1', 'install', 'Brazil') | 0.330097 |
|
||||
| ('Media_source_1', 'purchase', 'Brazil') | 0.850925 |
|
||||
| ('Media_source_1', 'install', 'Russia') | 0.319666 |
|
||||
| ('Media_source_1', 'purchase', 'Russia') | 0.724876 |
|
||||
| ('Media_source_1', 'install', 'Ukrane') | 0.917769 |
|
||||
| ('Media_source_1', 'purchase', 'Ukrane') | 0.343303 |
|
||||
| ('Media_source_2', 'install', 'Brazil') | 5.33726 |
|
||||
| ('Media_source_2', 'install', 'English_speaking') | 3.90023 |
|
||||
9
Aigrind/tables/payback-period.sorted.csv
Normal file
@@ -0,0 +1,9 @@
|
||||
Media Source,Campaign type,Target,"Time, (months)"
|
||||
Media_source_1,install,Russia,0.3196661081626587
|
||||
Media_source_1,install,Brazil,0.3300967979179157
|
||||
Media_source_1,purchase,Ukrane,0.3433033484234126
|
||||
Media_source_1,purchase,Russia,0.724875510844611
|
||||
Media_source_1,purchase,Brazil,0.8509252137211926
|
||||
Media_source_1,install,Ukrane,0.9177685774719259
|
||||
Media_source_2,install,English_speaking,3.9002341108208425
|
||||
Media_source_2,install,Brazil,5.337257113760678
|
||||
|
10
Aigrind/tables/payback-period.sorted.md
Normal file
@@ -0,0 +1,10 @@
|
||||
| | Time, (months) |
|
||||
|:--------------------------------------------------|-----------------:|
|
||||
| ('Media_source_1', 'install', 'Russia') | 0.319666 |
|
||||
| ('Media_source_1', 'install', 'Brazil') | 0.330097 |
|
||||
| ('Media_source_1', 'purchase', 'Ukrane') | 0.343303 |
|
||||
| ('Media_source_1', 'purchase', 'Russia') | 0.724876 |
|
||||
| ('Media_source_1', 'purchase', 'Brazil') | 0.850925 |
|
||||
| ('Media_source_1', 'install', 'Ukrane') | 0.917769 |
|
||||
| ('Media_source_2', 'install', 'English_speaking') | 3.90023 |
|
||||
| ('Media_source_2', 'install', 'Brazil') | 5.33726 |
|
||||
66
egeland/sql/Script.sql
Normal file
@@ -0,0 +1,66 @@
|
||||
with final_table2 as
|
||||
(with pre_table as
|
||||
(select
|
||||
*,
|
||||
-- Перевод из unix-времени в обычное
|
||||
cast(to_timestamp(created_at) as time) as dtime,
|
||||
-- удаление подряд идущих сообщений от одного пользователя по принципу проверки равенства
|
||||
-- между автором текущего и предыдущего сообщения (true, если авторы разные)
|
||||
-- coalesce -- чтобы NULL заменить на true у первого сообщения в сделке
|
||||
coalesce(created_by <> lag(created_by) over(partition by entity_id order by created_at), true) as not_dupl,
|
||||
-- нумерация записей внутри сделки, чтобы все сделки начинались с сообщения клиента
|
||||
row_number() over(partition by entity_id order by created_at) as num
|
||||
from
|
||||
db1.test.chat_messages cm
|
||||
order by entity_id, created_at)
|
||||
select
|
||||
*,
|
||||
dtime,
|
||||
-- учет нерабочего времени, возможны 4 варианта
|
||||
-- 1) менеджер ответил ночью -- тогда время ответа равно 24:00 - `время сообщения клиента`
|
||||
-- 2) клиент написал ночью -- тогда время ответа отсчитывается от 09:30
|
||||
-- 3) клиент написал днем, а менеджер ответил на след. день -- тогда время ответа равно
|
||||
-- разности времен сообщений за вычетом ночного времени
|
||||
-- 4) обычный вариант, тогда просто разность
|
||||
case when (dtime < '09:30:00'::time and created_by <> 0)
|
||||
then '24:00:00'::time - lag(dtime) over(partition by entity_id order by created_at)
|
||||
when (dtime < '09:30:00'::time and created_by = 0)
|
||||
then dtime -'09:30:00'::time
|
||||
when (lag(dtime) over(partition by entity_id order by created_at) > dtime)
|
||||
then lag(dtime) over(partition by entity_id order by created_at) - dtime - '09:30:00'::time
|
||||
else dtime - lag(dtime) over(partition by entity_id order by created_at)
|
||||
end as diff_time
|
||||
from pre_table
|
||||
where
|
||||
-- игнорируем дупликаты
|
||||
pre_table.not_dupl
|
||||
and
|
||||
-- игнорируем записи в сделках, которые начинаются с сообщения менеджера
|
||||
not (pre_table.num = 1 and pre_table.created_by <> 0))
|
||||
select
|
||||
r.rop_name,
|
||||
m.name_mop,
|
||||
-- приведение к timestamp для фильтрации в datalens
|
||||
cast(to_timestamp(created_at) as timestamp) as datetime,
|
||||
-- datalens не поддерживает тип данных interval
|
||||
extract(epoch from diff_time) as diff_time,
|
||||
avg(extract(epoch from diff_time)) over(partition by r.rop_name, m.name_mop) as avg_diff_time
|
||||
from
|
||||
-- обычный INNER JOIN трех таблиц
|
||||
final_table2 as ft2
|
||||
join
|
||||
managers as m on m.mop_id = ft2.created_by
|
||||
join
|
||||
-- пришлось привести m.rop_id к int4, так как разные типы
|
||||
rops as r on r.rop_id = cast(m.rop_id as int4)
|
||||
where
|
||||
created_by <> 0
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
852
egeland/test-task.ipynb
Normal file
@@ -0,0 +1,852 @@
|
||||
{
|
||||
"cells": [
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "724c2204",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"# Библиотеки"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 39,
|
||||
"id": "c2845a30",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"import numpy as np\n",
|
||||
"import pandas as pd\n",
|
||||
"import matplotlib.pyplot as plt\n",
|
||||
"import seaborn as sns\n",
|
||||
"from tqdm import tqdm\n",
|
||||
"\n",
|
||||
"plt.rcParams.update({'font.size': 14})"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 40,
|
||||
"id": "7c4025d7",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"from datetime import timedelta"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "d4c4405a",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"## Отключение предупреждений\n",
|
||||
"\n",
|
||||
"Возникали на этапе подключение к СУБД"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 41,
|
||||
"id": "f7cfd67c",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"import warnings\n",
|
||||
"warnings.filterwarnings('ignore')"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 42,
|
||||
"id": "c573a116",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"import psycopg2"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "69997e6b",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"# Константы"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 43,
|
||||
"id": "3e3370fe",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"USER = \"test_user\"\n",
|
||||
"PASSWORD = \"j2M{CnnFq@\" # Лучше, через переменные окружения, но это в целям экономии времени\n",
|
||||
"HOSTNAME = \"rc1a-p8bp15mmxsfwpbt0.mdb.yandexcloud.net\"\n",
|
||||
"# HOSTNAME = \"130.193.48.126\" # Были проблемы с разыменовыванием доменного имени\n",
|
||||
"DATABASE = \"db1\"\n",
|
||||
"PORT = '6432'"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "ec3cb72e",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"# Тестовое задание"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "d1635ad4",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"## Подключение к базе данных"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 44,
|
||||
"id": "e51e0bc4",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"conn = psycopg2.connect(\n",
|
||||
" database=DATABASE,\n",
|
||||
" user=USER,\n",
|
||||
" host=HOSTNAME,\n",
|
||||
" password=PASSWORD,\n",
|
||||
" port = PORT\n",
|
||||
")"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "markdown",
|
||||
"id": "3790de39",
|
||||
"metadata": {},
|
||||
"source": [
|
||||
"## Получение таблиц из запроса"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 45,
|
||||
"id": "05d856c8",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Запросы\n",
|
||||
"cm = pd.read_sql_query(\"select * from test.chat_messages\", conn)\n",
|
||||
"mop = pd.read_sql_query(\"select * from test.managers\", conn)\n",
|
||||
"rop = pd.read_sql_query(\"select * from test.rops\", conn)\n",
|
||||
"\n",
|
||||
"# Сортировка таблицы по времени сообщения\n",
|
||||
"cm.sort_values(by=['created_at'], ascending=True, inplace=True)\n",
|
||||
"\n",
|
||||
"# Приведение к типу строки, что нужно для операции JOIN\n",
|
||||
"rop['rop_id'] = rop['rop_id'].astype(str)\n",
|
||||
"\n",
|
||||
"# Установка первичных ключей в качестве индексов\n",
|
||||
"mop.set_index('mop_id', inplace=True)\n",
|
||||
"cm.set_index('message_id', inplace=True)\n",
|
||||
"rop.set_index('rop_id', inplace=True)"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 46,
|
||||
"id": "4de1c50d",
|
||||
"metadata": {},
|
||||
"outputs": [
|
||||
{
|
||||
"data": {
|
||||
"text/html": [
|
||||
"<div>\n",
|
||||
"<style scoped>\n",
|
||||
" .dataframe tbody tr th:only-of-type {\n",
|
||||
" vertical-align: middle;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe tbody tr th {\n",
|
||||
" vertical-align: top;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe thead th {\n",
|
||||
" text-align: right;\n",
|
||||
" }\n",
|
||||
"</style>\n",
|
||||
"<table border=\"1\" class=\"dataframe\">\n",
|
||||
" <thead>\n",
|
||||
" <tr style=\"text-align: right;\">\n",
|
||||
" <th></th>\n",
|
||||
" <th>type</th>\n",
|
||||
" <th>entity_id</th>\n",
|
||||
" <th>created_by</th>\n",
|
||||
" <th>created_at</th>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>message_id</th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" </tr>\n",
|
||||
" </thead>\n",
|
||||
" <tbody>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qn9kwq95f3cm3w9pte8m7\"</th>\n",
|
||||
" <td>outgoing_chat_message</td>\n",
|
||||
" <td>37548741</td>\n",
|
||||
" <td>10262513</td>\n",
|
||||
" <td>1729890002</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnbwyqywemwww3kxh8wxp\"</th>\n",
|
||||
" <td>outgoing_chat_message</td>\n",
|
||||
" <td>36713959</td>\n",
|
||||
" <td>10262485</td>\n",
|
||||
" <td>1729890004</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qney0mkr94bx272g4qhs3\"</th>\n",
|
||||
" <td>incoming_chat_message</td>\n",
|
||||
" <td>37548761</td>\n",
|
||||
" <td>0</td>\n",
|
||||
" <td>1729890008</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnhnkb0n83mrg790xjn82\"</th>\n",
|
||||
" <td>outgoing_chat_message</td>\n",
|
||||
" <td>37548087</td>\n",
|
||||
" <td>6744792</td>\n",
|
||||
" <td>1729890010</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnmn7asjn9m5478zy7c82\"</th>\n",
|
||||
" <td>outgoing_chat_message</td>\n",
|
||||
" <td>37362585</td>\n",
|
||||
" <td>10465690</td>\n",
|
||||
" <td>1729890013</td>\n",
|
||||
" </tr>\n",
|
||||
" </tbody>\n",
|
||||
"</table>\n",
|
||||
"</div>"
|
||||
],
|
||||
"text/plain": [
|
||||
" type entity_id created_by \\\n",
|
||||
"message_id \n",
|
||||
"\"01jb2qn9kwq95f3cm3w9pte8m7\" outgoing_chat_message 37548741 10262513 \n",
|
||||
"\"01jb2qnbwyqywemwww3kxh8wxp\" outgoing_chat_message 36713959 10262485 \n",
|
||||
"\"01jb2qney0mkr94bx272g4qhs3\" incoming_chat_message 37548761 0 \n",
|
||||
"\"01jb2qnhnkb0n83mrg790xjn82\" outgoing_chat_message 37548087 6744792 \n",
|
||||
"\"01jb2qnmn7asjn9m5478zy7c82\" outgoing_chat_message 37362585 10465690 \n",
|
||||
"\n",
|
||||
" created_at \n",
|
||||
"message_id \n",
|
||||
"\"01jb2qn9kwq95f3cm3w9pte8m7\" 1729890002 \n",
|
||||
"\"01jb2qnbwyqywemwww3kxh8wxp\" 1729890004 \n",
|
||||
"\"01jb2qney0mkr94bx272g4qhs3\" 1729890008 \n",
|
||||
"\"01jb2qnhnkb0n83mrg790xjn82\" 1729890010 \n",
|
||||
"\"01jb2qnmn7asjn9m5478zy7c82\" 1729890013 "
|
||||
]
|
||||
},
|
||||
"execution_count": 46,
|
||||
"metadata": {},
|
||||
"output_type": "execute_result"
|
||||
}
|
||||
],
|
||||
"source": [
|
||||
"cm.head()"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 47,
|
||||
"id": "4fae9113",
|
||||
"metadata": {},
|
||||
"outputs": [
|
||||
{
|
||||
"data": {
|
||||
"text/html": [
|
||||
"<div>\n",
|
||||
"<style scoped>\n",
|
||||
" .dataframe tbody tr th:only-of-type {\n",
|
||||
" vertical-align: middle;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe tbody tr th {\n",
|
||||
" vertical-align: top;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe thead th {\n",
|
||||
" text-align: right;\n",
|
||||
" }\n",
|
||||
"</style>\n",
|
||||
"<table border=\"1\" class=\"dataframe\">\n",
|
||||
" <thead>\n",
|
||||
" <tr style=\"text-align: right;\">\n",
|
||||
" <th></th>\n",
|
||||
" <th>name_mop</th>\n",
|
||||
" <th>rop_id</th>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>mop_id</th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" </tr>\n",
|
||||
" </thead>\n",
|
||||
" <tbody>\n",
|
||||
" <tr>\n",
|
||||
" <th>6645315</th>\n",
|
||||
" <td>Гюнель и Илина</td>\n",
|
||||
" <td>1</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>6744792</th>\n",
|
||||
" <td>Юля и Наташа</td>\n",
|
||||
" <td>1</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>10262505</th>\n",
|
||||
" <td>Вика и Марго</td>\n",
|
||||
" <td>1</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>10262513</th>\n",
|
||||
" <td>Ира и Варя</td>\n",
|
||||
" <td>1</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>10465254</th>\n",
|
||||
" <td>Настя и Даша</td>\n",
|
||||
" <td>1</td>\n",
|
||||
" </tr>\n",
|
||||
" </tbody>\n",
|
||||
"</table>\n",
|
||||
"</div>"
|
||||
],
|
||||
"text/plain": [
|
||||
" name_mop rop_id\n",
|
||||
"mop_id \n",
|
||||
"6645315 Гюнель и Илина 1\n",
|
||||
"6744792 Юля и Наташа 1\n",
|
||||
"10262505 Вика и Марго 1\n",
|
||||
"10262513 Ира и Варя 1\n",
|
||||
"10465254 Настя и Даша 1"
|
||||
]
|
||||
},
|
||||
"execution_count": 47,
|
||||
"metadata": {},
|
||||
"output_type": "execute_result"
|
||||
}
|
||||
],
|
||||
"source": [
|
||||
"mop.head()"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 48,
|
||||
"id": "ddd63eab",
|
||||
"metadata": {},
|
||||
"outputs": [
|
||||
{
|
||||
"data": {
|
||||
"text/html": [
|
||||
"<div>\n",
|
||||
"<style scoped>\n",
|
||||
" .dataframe tbody tr th:only-of-type {\n",
|
||||
" vertical-align: middle;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe tbody tr th {\n",
|
||||
" vertical-align: top;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe thead th {\n",
|
||||
" text-align: right;\n",
|
||||
" }\n",
|
||||
"</style>\n",
|
||||
"<table border=\"1\" class=\"dataframe\">\n",
|
||||
" <thead>\n",
|
||||
" <tr style=\"text-align: right;\">\n",
|
||||
" <th></th>\n",
|
||||
" <th>rop_name</th>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>rop_id</th>\n",
|
||||
" <th></th>\n",
|
||||
" </tr>\n",
|
||||
" </thead>\n",
|
||||
" <tbody>\n",
|
||||
" <tr>\n",
|
||||
" <th>1</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>2</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>3</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" </tr>\n",
|
||||
" </tbody>\n",
|
||||
"</table>\n",
|
||||
"</div>"
|
||||
],
|
||||
"text/plain": [
|
||||
" rop_name\n",
|
||||
"rop_id \n",
|
||||
"1 Катя РОП\n",
|
||||
"2 Полина РОП\n",
|
||||
"3 Эля РОП"
|
||||
]
|
||||
},
|
||||
"execution_count": 48,
|
||||
"metadata": {},
|
||||
"output_type": "execute_result"
|
||||
}
|
||||
],
|
||||
"source": [
|
||||
"rop.head()"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 49,
|
||||
"id": "6da1229a",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"def time_diff(x):\n",
|
||||
" \"\"\"\n",
|
||||
" Функция, которая на каждую строку в таблице chat_members, считает время ответа по\n",
|
||||
" следующим правилам:\n",
|
||||
" 1) менеджер ответил ночью -- тогда время ответа равно 24:00 - `время сообщения клиента`\n",
|
||||
" 2) клиент написал ночью -- тогда время ответа отсчитывается от 09:30\n",
|
||||
" 3) клиент написал днем, а менеджер ответил на след. день -- тогда время ответа равно\n",
|
||||
" разности времен сообщений за вычетом ночного времени\n",
|
||||
" 4) обычный вариант, тогда просто разность\n",
|
||||
" \"\"\"\n",
|
||||
" shift_begin = timedelta(hours=9, minutes=30)\n",
|
||||
" day = timedelta(days=1)\n",
|
||||
" ct = x['dtime']\n",
|
||||
" mt = x['lag_dtime']\n",
|
||||
" manager_time = timedelta(seconds=mt.second, minutes=mt.minute, hours=mt.hour)\n",
|
||||
" client_time = timedelta(seconds=ct.second, minutes=ct.minute, hours=ct.hour)\n",
|
||||
" if manager_time < shift_begin:\n",
|
||||
" return day - client_time\n",
|
||||
" elif client_time < shift_begin:\n",
|
||||
" return manager_time - shift_begin\n",
|
||||
" elif client_time > manager_time:\n",
|
||||
" return client_time - manager_time - shift_begin\n",
|
||||
" else:\n",
|
||||
" return manager_time - client_time"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 50,
|
||||
"id": "e7f4d343",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Добавление столбца с временем суток\n",
|
||||
"cm['dtime'] = pd.to_datetime(cm['created_at'], unit='s').dt.time"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 51,
|
||||
"id": "80dc378b",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Аналог \n",
|
||||
"# ROW_NUMBER() OVER(PARTITION BY entity_id ORDER BY created_at) \n",
|
||||
"# из SQL\n",
|
||||
"# Нужно, чтобы установить порядок сообщений внутри одной сделки и \n",
|
||||
"# отфильтровать те, в которых первое сообщение написал менеджер\n",
|
||||
"cm['num'] = cm.sort_values('created_at').groupby(by=['entity_id']).cumcount()+1\n",
|
||||
"condition1 = np.logical_not(np.logical_and(cm['created_by'] != 0, cm['num'] == 0))"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 52,
|
||||
"id": "79d51892",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Аналог\n",
|
||||
"# created_by <> lag(created_by) OVER(PARTITION BY entity_id ORDER BY created_at\n",
|
||||
"# из SQL\n",
|
||||
"# Сдвигает значение на одну позицию, чтобы отфильтровать те сообщение, идущие подряд,\n",
|
||||
"# которые написаны одним человеком\n",
|
||||
"cm['lag'] = cm.sort_values('created_at').groupby(by=['entity_id'])['created_by'].shift(-1)\n",
|
||||
"condition2 = cm['created_by'] != cm['lag']"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 53,
|
||||
"id": "856be093",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Фильтр по пересечению условий\n",
|
||||
"result = cm[condition1 & condition2]"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 54,
|
||||
"id": "ab1e36bc",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Сдвиг времени сообщения на одну позицию, чтобы получить разницу времен сообщений\n",
|
||||
"result['lag_dtime'] = result.sort_values('created_at').groupby('entity_id')['dtime'].shift(-1)\n",
|
||||
"result['lag_diff'] = result.dropna().apply(time_diff, axis=1)"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 55,
|
||||
"id": "eedbdf11",
|
||||
"metadata": {},
|
||||
"outputs": [
|
||||
{
|
||||
"data": {
|
||||
"text/html": [
|
||||
"<div>\n",
|
||||
"<style scoped>\n",
|
||||
" .dataframe tbody tr th:only-of-type {\n",
|
||||
" vertical-align: middle;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe tbody tr th {\n",
|
||||
" vertical-align: top;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe thead th {\n",
|
||||
" text-align: right;\n",
|
||||
" }\n",
|
||||
"</style>\n",
|
||||
"<table border=\"1\" class=\"dataframe\">\n",
|
||||
" <thead>\n",
|
||||
" <tr style=\"text-align: right;\">\n",
|
||||
" <th></th>\n",
|
||||
" <th>name_mop</th>\n",
|
||||
" <th>rop_name</th>\n",
|
||||
" <th>lag_diff</th>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>message_id</th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" <th></th>\n",
|
||||
" </tr>\n",
|
||||
" </thead>\n",
|
||||
" <tbody>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qn9kwq95f3cm3w9pte8m7\"</th>\n",
|
||||
" <td>Ира и Варя</td>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>0 days 00:02:49</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnhnkb0n83mrg790xjn82\"</th>\n",
|
||||
" <td>Юля и Наташа</td>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>0 days 00:00:15</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnmn7asjn9m5478zy7c82\"</th>\n",
|
||||
" <td>Настя и Малика</td>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>0 days 00:00:09</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qnvamsq2866te84re669b\"</th>\n",
|
||||
" <td>Соня и Катя</td>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>0 days 00:00:27</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>\"01jb2qpc1qfrqgmgx998t9vgg2\"</th>\n",
|
||||
" <td>Мария и Соня</td>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>0 days 00:00:23</td>\n",
|
||||
" </tr>\n",
|
||||
" </tbody>\n",
|
||||
"</table>\n",
|
||||
"</div>"
|
||||
],
|
||||
"text/plain": [
|
||||
" name_mop rop_name lag_diff\n",
|
||||
"message_id \n",
|
||||
"\"01jb2qn9kwq95f3cm3w9pte8m7\" Ира и Варя Катя РОП 0 days 00:02:49\n",
|
||||
"\"01jb2qnhnkb0n83mrg790xjn82\" Юля и Наташа Катя РОП 0 days 00:00:15\n",
|
||||
"\"01jb2qnmn7asjn9m5478zy7c82\" Настя и Малика Эля РОП 0 days 00:00:09\n",
|
||||
"\"01jb2qnvamsq2866te84re669b\" Соня и Катя Полина РОП 0 days 00:00:27\n",
|
||||
"\"01jb2qpc1qfrqgmgx998t9vgg2\" Мария и Соня Полина РОП 0 days 00:00:23"
|
||||
]
|
||||
},
|
||||
"execution_count": 55,
|
||||
"metadata": {},
|
||||
"output_type": "execute_result"
|
||||
}
|
||||
],
|
||||
"source": [
|
||||
"# Объединение таблиц для получения конечных времен реакций на сообщения\n",
|
||||
"result2 = result.join(mop, on='created_by').join(rop, on='rop_id').dropna()[['name_mop', 'rop_name', 'lag_diff']]\n",
|
||||
"result2.head()"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 56,
|
||||
"id": "c7038cc6",
|
||||
"metadata": {},
|
||||
"outputs": [],
|
||||
"source": [
|
||||
"# Группировка и применение агрегирующей функции\n",
|
||||
"final_df = result2.groupby(by=['rop_name', 'name_mop']).mean()"
|
||||
]
|
||||
},
|
||||
{
|
||||
"cell_type": "code",
|
||||
"execution_count": 59,
|
||||
"id": "0e3440d5",
|
||||
"metadata": {},
|
||||
"outputs": [
|
||||
{
|
||||
"data": {
|
||||
"text/html": [
|
||||
"<div>\n",
|
||||
"<style scoped>\n",
|
||||
" .dataframe tbody tr th:only-of-type {\n",
|
||||
" vertical-align: middle;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe tbody tr th {\n",
|
||||
" vertical-align: top;\n",
|
||||
" }\n",
|
||||
"\n",
|
||||
" .dataframe thead th {\n",
|
||||
" text-align: right;\n",
|
||||
" }\n",
|
||||
"</style>\n",
|
||||
"<table border=\"1\" class=\"dataframe\">\n",
|
||||
" <thead>\n",
|
||||
" <tr style=\"text-align: right;\">\n",
|
||||
" <th></th>\n",
|
||||
" <th>Имя руководителя</th>\n",
|
||||
" <th>Имя менеджера</th>\n",
|
||||
" <th>Среднее время реакции</th>\n",
|
||||
" </tr>\n",
|
||||
" </thead>\n",
|
||||
" <tbody>\n",
|
||||
" <tr>\n",
|
||||
" <th>0</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Аня и Ксюша</td>\n",
|
||||
" <td>0 days 03:27:30.020872865</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>1</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Вика и Катя</td>\n",
|
||||
" <td>0 days 03:24:13.302118171</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>2</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Гюнель и Илина</td>\n",
|
||||
" <td>0 days 03:55:31.088691796</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>3</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Ира и Варя</td>\n",
|
||||
" <td>0 days 02:44:58.748677248</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>4</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Ксюша и Джамиля</td>\n",
|
||||
" <td>0 days 01:58:12.669724770</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>5</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Настя и Даша</td>\n",
|
||||
" <td>0 days 03:28:37.838951310</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>6</th>\n",
|
||||
" <td>Катя РОП</td>\n",
|
||||
" <td>Юля и Наташа</td>\n",
|
||||
" <td>0 days 03:57:47.909896602</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>7</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Даша и Влада</td>\n",
|
||||
" <td>0 days 03:48:25.811715481</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>8</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Даша и Даша</td>\n",
|
||||
" <td>0 days 03:27:55.650793650</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>9</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Лиза и Ева</td>\n",
|
||||
" <td>0 days 03:19:41.608280254</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>10</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Мария и Соня</td>\n",
|
||||
" <td>0 days 03:16:59.401098901</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>11</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Настя и Саша</td>\n",
|
||||
" <td>0 days 02:36:18.021337126</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>12</th>\n",
|
||||
" <td>Полина РОП</td>\n",
|
||||
" <td>Соня и Катя</td>\n",
|
||||
" <td>0 days 01:35:07.795180722</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>13</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Алина и Юля</td>\n",
|
||||
" <td>0 days 02:28:19.712707182</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>14</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Ангелина Милованова</td>\n",
|
||||
" <td>0 days 06:06:26.477272727</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>15</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Влада и Настя</td>\n",
|
||||
" <td>0 days 00:28:08.972222222</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>16</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Даша и Карина</td>\n",
|
||||
" <td>0 days 02:38:46.333333333</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>17</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Ками и Мила</td>\n",
|
||||
" <td>0 days 02:23:03.636904761</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>18</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Настя и Малика</td>\n",
|
||||
" <td>0 days 02:57:01.780487804</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>19</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Полина Мирзоян</td>\n",
|
||||
" <td>0 days 01:55:44.690476190</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>20</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Порхачева Полина</td>\n",
|
||||
" <td>0 days 05:06:48.200000</td>\n",
|
||||
" </tr>\n",
|
||||
" <tr>\n",
|
||||
" <th>21</th>\n",
|
||||
" <td>Эля РОП</td>\n",
|
||||
" <td>Софья Боднар</td>\n",
|
||||
" <td>0 days 03:26:38.134831460</td>\n",
|
||||
" </tr>\n",
|
||||
" </tbody>\n",
|
||||
"</table>\n",
|
||||
"</div>"
|
||||
],
|
||||
"text/plain": [
|
||||
" Имя руководителя Имя менеджера Среднее время реакции\n",
|
||||
"0 Катя РОП Аня и Ксюша 0 days 03:27:30.020872865\n",
|
||||
"1 Катя РОП Вика и Катя 0 days 03:24:13.302118171\n",
|
||||
"2 Катя РОП Гюнель и Илина 0 days 03:55:31.088691796\n",
|
||||
"3 Катя РОП Ира и Варя 0 days 02:44:58.748677248\n",
|
||||
"4 Катя РОП Ксюша и Джамиля 0 days 01:58:12.669724770\n",
|
||||
"5 Катя РОП Настя и Даша 0 days 03:28:37.838951310\n",
|
||||
"6 Катя РОП Юля и Наташа 0 days 03:57:47.909896602\n",
|
||||
"7 Полина РОП Даша и Влада 0 days 03:48:25.811715481\n",
|
||||
"8 Полина РОП Даша и Даша 0 days 03:27:55.650793650\n",
|
||||
"9 Полина РОП Лиза и Ева 0 days 03:19:41.608280254\n",
|
||||
"10 Полина РОП Мария и Соня 0 days 03:16:59.401098901\n",
|
||||
"11 Полина РОП Настя и Саша 0 days 02:36:18.021337126\n",
|
||||
"12 Полина РОП Соня и Катя 0 days 01:35:07.795180722\n",
|
||||
"13 Эля РОП Алина и Юля 0 days 02:28:19.712707182\n",
|
||||
"14 Эля РОП Ангелина Милованова 0 days 06:06:26.477272727\n",
|
||||
"15 Эля РОП Влада и Настя 0 days 00:28:08.972222222\n",
|
||||
"16 Эля РОП Даша и Карина 0 days 02:38:46.333333333\n",
|
||||
"17 Эля РОП Ками и Мила 0 days 02:23:03.636904761\n",
|
||||
"18 Эля РОП Настя и Малика 0 days 02:57:01.780487804\n",
|
||||
"19 Эля РОП Полина Мирзоян 0 days 01:55:44.690476190\n",
|
||||
"20 Эля РОП Порхачева Полина 0 days 05:06:48.200000\n",
|
||||
"21 Эля РОП Софья Боднар 0 days 03:26:38.134831460"
|
||||
]
|
||||
},
|
||||
"execution_count": 59,
|
||||
"metadata": {},
|
||||
"output_type": "execute_result"
|
||||
}
|
||||
],
|
||||
"source": [
|
||||
"di = {\n",
|
||||
" 'name_mop': \"Имя менеджера\",\n",
|
||||
" 'rop_name': \"Имя руководителя\",\n",
|
||||
" 'lag_diff': \"Среднее время реакции\",\n",
|
||||
"}\n",
|
||||
"\n",
|
||||
"# Более красивое отображение\n",
|
||||
"final_df.reset_index().rename(di, axis=1)"
|
||||
]
|
||||
}
|
||||
],
|
||||
"metadata": {
|
||||
"kernelspec": {
|
||||
"display_name": "Python 3 (ipykernel)",
|
||||
"language": "python",
|
||||
"name": "python3"
|
||||
},
|
||||
"language_info": {
|
||||
"codemirror_mode": {
|
||||
"name": "ipython",
|
||||
"version": 3
|
||||
},
|
||||
"file_extension": ".py",
|
||||
"mimetype": "text/x-python",
|
||||
"name": "python",
|
||||
"nbconvert_exporter": "python",
|
||||
"pygments_lexer": "ipython3",
|
||||
"version": "3.13.1"
|
||||
}
|
||||
},
|
||||
"nbformat": 4,
|
||||
"nbformat_minor": 5
|
||||
}
|
||||