alertas-databricks-to-teams.ipynb

{"metadata":{"kernelspec":{"language":"python","display_name":"Python 3","name":"python3"},"language_info":{"pygments_lexer":"ipython3","nbconvert_exporter":"python","version":"3.6.4","file_extension":".py","codemirror_mode":{"name":"ipython","version":3},"name":"python","mimetype":"text/x-python"},"kaggle":{"accelerator":"none","dataSources":[],"isInternetEnabled":true,"language":"python","sourceType":"notebook","isGpuEnabled":false}},"nbformat_minor":4,"nbformat":4,"cells":[{"cell_type":"code","source":"%python\nimport pymsteams\nimport pandas as pd\nimport pyspark.sql.functions as F\nimport pyspark.sql as S\nimport requests\n\ndf = sqlContext.sql(\"\"\"\nselect codigo_x AS QTD_CLI,\n date_format(atualizacao,'yyyyMM' )  AS DATA_REFERENCIA\n from --PATH.SUA_TABLE\nWHERE xpto1 = 'F' \nAND xpto2 between '2024-06-01' AND '2024-06-31' \nAND xpto3 IN ('004', '005', '006', '007', '106','001', '002', '003', '304','009')\nAND xpto4 IN ('N')\nAND atualizacao = '2024-06-28'\n\"\"\")\n\nif (df.count() > 0):\n    texto = \"MONITORAMENTO XPTO - CLOUD \\n\"\n    texto = texto + \"\\n\"\n\n    if (df.count() < 488000):\n      texto = texto + \"TEXTO \" + str(df.count()) + \" TEXTO \\n\"\n    else:\n      texto = texto + \"TEXTO \" + str(df.count()) + \" TEXTO_ERRO. Verificar a query. \\n\"\n\n    print(texto)\n\n    \nmyTeamsMessage = pymsteams.connectorcard(\"conector webhook\")\nmyTeamsMessage.text(texto)\nmyTeamsMessage.send()\n    ","metadata":{"_uuid":"8f2839f25d086af736a60e9eeb907d3b93b6e0e5","_cell_guid":"b1076dfc-b9ad-4769-8c92-a6c4dae69d19","trusted":true},"outputs":[],"execution_count":null}]}