Skip to content

Commit

Permalink
Merge pull request #7 from octaflop/patch-1
Browse files Browse the repository at this point in the history
Fix SQL setup typos in pipelines.md
  • Loading branch information
trallard committed May 2, 2019
2 parents a9d511c + 9d3b550 commit 5a70e27
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions source/pipelines.md
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ mysql>
```
you can also see the users and the relevant hosts using the following command
```sql
SELECT user, host, FROM mysql.user;
SELECT user, host FROM mysql.user;
```
We will need to create a new database for the following sections. So let's start by creating a new database called `airflowdb`:

Expand All @@ -124,7 +124,7 @@ For this tutorial let's assume the password is `python2019`.
Now we need to make sure that the `airflow` user has access to the databases:
```sql
GRANT ALL PRIVILEGES ON *.* TO 'airflow'@'localhost';
FLUSH PRIVILEGES'
FLUSH PRIVILEGES;
```

If you want to restrict the access of this user to the `airflowdb` database, for example, you can do it via:
Expand Down Expand Up @@ -628,4 +628,4 @@ if __name__ == "__main__":

🚦In pairs discuss:
- How would you run the two scripts together?
- Try and create the pipeline: `stream_twitter.py` -> `analyse_twitter.py`
- Try and create the pipeline: `stream_twitter.py` -> `analyse_twitter.py`

0 comments on commit 5a70e27

Please sign in to comment.